inlong
inlong copied to clipboard
apache
Apache InLong - a one-stop, full-scenario integration framework for massive data
### Description [Feature] improve agent InlongDatabaseHistory implementation ### Use case [Feature] improve agent InlongDatabaseHistory implementation ### Are you willing to submit PR? - [X] Yes, I am willing to submit...
### Description _No response_ ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct...
### Prepare a Pull Request *(Change the title refer to the following example)* - Title Example: [INLONG-XYZ][Component] Title of the pull request *(The following *XYZ* should be replaced by the...
### Description 1. Change cluster tag of a inlong group id. 2. Change Partition number of a inlong group id. 3. Change sort cluster of a inlong stream. ### Use...
### Description 1. Control produce operation and consume operation of Inlong message queue cluster. 2. Build relationships between DataProxy cluster and MessageQueue cluster. 3. Remove relationships between DataProxy cluster and...
### Description 1. Create a topic in all message queue of Cluster Tag. 2. Delete a topic from all message queue of Cluster Tag. 3. Change retention policies about all...
### Prepare a Pull Request - Title: [INLONG-5628][DataProxy] Add buffer limit of sink dispatch queue - Fixes #5628 ### Motivation *Explain here the context, and why you're making that change....
### Description Remove the unused data consumption related classes. ### InLong Component InLong Manager ### Are you willing to submit PR? - [X] Yes, I am willing to submit a...
### Prepare a Pull Request - Fixes https://github.com/apache/inlong/issues/5133 ### Motivation Add Apache InfluxDB Extract for Sort ### Modifications The details can be found at https://github.com/apache/inlong/issues/5133. ### Verifying this change *(Please...
### Prepare a Pull Request - Fixes https://github.com/apache/inlong/issues/5133 ### Motivation Add influx DB sink for sort. ### Modifications 1. Implement the influxDBLoadNode 2. Implement the InfluxDBDialect 3. Move an influxDB-JDBC-driver...