inlong

inlong copied to clipboard

[Umbrella][Manager] Modify the calling method from SDK to HTTP

2

### Describe the proposal The Manager component uses SDK to execute processes for different services, like Pulsar/Kafka/Elasticsearch... Using SDK will cause many dependencies, and we could modify the calling method...

dockerzhang

[Feature] [Sort] Add Dameng Connector for flink 1.13

1

### Description DataInlong wants to support more sources and sinks in 2024. DMV8 cdc connector is a new cdc connector which is tested but still needs more finetuning. it has...

Yizhou-Yang

[Feature] [Manager] Add Dameng Connector for flink 1.13

1

### Description Dameng connector inlong manager and inlong common changes ### Use case _No response_ ### Are you willing to submit PR? - [X] Yes, I am willing to submit...

Yizhou-Yang

[Feature][Sort] Add ElasticSearch connector on Flink 1.15

1

### Description Add ElasticSearch connector on Flink 1.15 ### Use case Add ElasticSearch connector on Flink 1.15 ### Are you willing to submit PR? - [X] Yes, I am willing...

EMsnap

[Bug] The data nodes should be displayed on the "source" and "sink" sides

2

### What happened According to the official website, "Data Nodes" should include "Extract Nodes" and "Load Nodes". However, when creating the "Ingestion" task, data nodes cannot be selected on the...

LiJie20190102

[Improve][Sort] Doris full database migration missing audit data

1

### Description Doris full database migration missing audit data  ### InLong Component InLong Sort ### Are you willing to submit PR? - [ ] Yes, I am willing to...

haifxu

[Feature][Sort] Sort connectors support audit ID

4

### Description - Different sink types correspond to different audit IDs, so the `Manager` will send this ID to `Sort`, but some sort-connectors do not support the use of this...

haifxu

[Bug][Manager] Failed to use Elasticsearch sink

1

### What happened When I used Elasticsearch as the data node, the configuration process encountered the following error: [ ] 2023-11-07 08:19:08.132 - INFO [inlong-mq-process-0] a.i.m.s.r.s.e.ElasticsearchApi:166 - create test_pulsar_table_es:true [...

haibo-duan

[Improve][Sort] Errors in UT test logs for sort-end-to-end-tests, but UT results show as successful

1

### Description - Case 1 https://github.com/apache/inlong/actions/runs/7081425279/job/19270686450  - Case https://github.com/apache/inlong/actions/runs/7081189588/job/19270165431?pr=9395  Errors in UT test logs for sort-end-to-end-tests, but UT results show as successful. ### InLong Component InLong Sort ###...

hnrainll

[Feature][Sort] Iceberg sink support write watermark in the snapshot

3

### Description Support write watermark in the snapshot. Many thanks to @XuQianJin-Stars for his contribution  ### Use case _No response_ ### Are you willing to submit PR? - [X]...

vernedeng