Xiangying Meng

Master Issue: https://github.com/apache/pulsar/issues/16913 ### Motivation Implement system topic client for snapshot segment topic and index topic to send segment snapshots or indexes. ### Modification Add a TransactionBufferSnapshotService to handle the...

[INLONG-4962][DataProxy] Unify the MQ zone sink

6

### Prepare a Pull Request - Fixes https://github.com/apache/inlong/issues/4962 ### Motivation&&Modifications implement AbstractClusterZoneProducer and AbstractSinkZoneContext. Implement the AbstractZoneProducer. implement the AbstractZoneSink and AbstractZoneWork.

[INLONG-5321][DataProxy] Add zone test for MQ sinks

2

### Prepare a Pull Request - Fixes https://github.com/apache/inlong/issues/5321 ### Motivation Now, the PulsarZoneSink, the KafkaZoneSink, and the TubeZoneSink have no test to verify. So we add a test to verify...

[Improve][DataProxy] Add zone sink test

1

### Description Now, the PulsarZoneSink, the KafkaZoneSink, and the TubeZoneSink have no test to verify. ### InLong Component InLong DataProxy ### Are you willing to submit PR? - [X] Yes,...

### Motivation The TransactionImpl stores a lot of future. This uses a lot of memory, and can be optimized to two futures. ### Modification Optimize the future list to single...

### Motivation Fix testGetTxnID, testSubscriptionRecreateTopic and testPendingAckMarkDeletePosition can not pass since the broker is not cleaned up. ### Modification fix the testGetTxnID, and move the testSubscriptionRecreateTopic and testPendingAckMarkDeletePosition to adapt...

### Motivation && Modification There is some mistake in the Failover subscription type. ### Verifying this change - [ ] Make sure that the change passes the CI checks. *(Please...

[INLONG-5133][Sort] Support InfluxDB extract node

4

### 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...

[INLONG-5133][Sort] Support InfluxDB load node and connector

1

### 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...

[fix][broker] Fix can not delete namespace by force

2

### Motivation 1. When we delete a namespace by force if the __transaction_buffer_snapshot and __change_events be deleted first, and then the deleting of the normal topic will be failed at...