inlong
inlong copied to clipboard
apache
Apache InLong - a one-stop, full-scenario integration framework for massive data
At present, the C/C++ SDK only supports consumer logic (https://issues.apache.org/jira/projects/TUBEMQ/issues/TUBEMQ-3?filter=doneissues), so it's not a complete SDK yet. Due to some reason, the original contributor did not continue.If you have an...
### Description Currently, we can't set the subscription name for the pulsar source, Flink connector will generate a subscription name combining `flink-sql-connector-pulsar` prefix with a random string suffix. This may...
### Prepare a Pull Request - Fixes #9873 ### Motivation Support adding supplementary recording tasks for file collection. ### Modifications Support adding supplementary recording tasks for file collection.
- Fixes #9876 ### Motivation optimize the format of error message ### Modifications optimize the format of error message. With this pul request, the error msg will be `Request to...
### What happened Manager-client print error message when met exception like : ```shell java.lang.IllegalArgumentException: Request to Inlong Inlong group already exists failed: null at org.apache.inlong.manager.common.util.Preconditions.expectTrue(Preconditions.java:138) at org.apache.inlong.manager.client.api.util.ClientUtils.assertRespSuccess(ClientUtils.java:121) at org.apache.inlong.manager.client.api.inner.client.InlongGroupClient.createGroup(InlongGroupClient.java:166) at...
https://github.com/apache/inlong/blame/92794e15f3a418ce2396f911f61cc38b41a3b9b0/inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java#L83
### Description Support adding supplementary recording tasks for file collection. ### InLong Component InLong Manager ### Are you willing to submit PR? - [X] Yes, I am willing to submit...
### Prepare a Pull Request - [INLONG-9866][Sort] Add end to end test case(redis to redis) for sort-connector-redis-v1.15. - Fixes #9866 ### Motivation Sort-connector-redis-v1.15 has not end to end test case...
### Prepare a Pull Request - Fixes #9867 9867 ### Motivation Unified configuration process for standalone and sortflink. The current configuration process of standalone has the following issues: 1. Configuration...
### Description Pulsar DataNode support to set compression type ### Use case Pulsar DataNode support to set compression type ### Are you willing to submit PR? - [X] Yes, I...
