[PR] [INLONG-10730][Manager] Fix auto-assign wrong Sortstandalone cluster when no cluster is under the tag [inlong]

vernedeng opened a new pull request, #10731: URL: https://github.com/apache/inlong/pull/10731 Fixes #10730 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [

Re: [PR] [INLONG-10730][Manager] Fix auto-assign wrong Sortstandalone cluster when no cluster is under the tag [inlong]

aloyszhang merged PR #10731: URL: https://github.com/apache/inlong/pull/10731 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

(inlong) branch master updated: [INLONG-10730][Manager] Fix auto-assign wrong Sortstandalone cluster when no cluster is under the tag (#10731)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 0aedc7789c [INLONG-10730][Manager] Fix auto-

[PR] [INLONG-10706][SDK] DataProxy SDK Shaded Native Library [inlong]

castorqin opened a new pull request, #10732: URL: https://github.com/apache/inlong/pull/10732 ### 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 repl

Re: [PR] [INLONG-10720][Sort] Add Elasticsearch6 connector on Flink 1.18 [inlong]

XiaoYou201 commented on PR #10722: URL: https://github.com/apache/inlong/pull/10722#issuecomment-2255702236 As follow image, I implement es 6 connector and postgreSQL to ElasticSearch6 test successfully . But due to the format-base module not compatible with flink 1.18, So, I have to submi

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

dockerzhang commented on PR #10727: URL: https://github.com/apache/inlong/pull/10727#issuecomment-2255864356 > I have fixed these issues, please review again, thank you! please click `resolve` if you fix the comment, thanks. -- This is an automated message from the Apache Git Servic

Re: [PR] [INLONG-10703][Manager] Manager Add Oceanbase Support [inlong]

dockerzhang commented on PR #10701: URL: https://github.com/apache/inlong/pull/10701#issuecomment-2255871382 @xxsc0529 you could ignore the CodeQL fails, but it's better to click `resolve` if you fix the comments. -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

qy-liuhuo commented on PR #10727: URL: https://github.com/apache/inlong/pull/10727#issuecomment-2255874275 > > I have fixed these issues, please review again, thank you! > > please click `resolve` if you fix the comment, thanks. ok，thanks -- This is an automated message from

[PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

vernedeng opened a new pull request, #10734: URL: https://github.com/apache/inlong/pull/10734 Fixes #10729 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

aloyszhang commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696098337 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/EsMapSinkEncoder.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

aloyszhang commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696099580 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/EsMapSinkInfo.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache Software Found

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

aloyszhang commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696099984 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/converter/TypeConverter.java: ## @@ -0,0 +1,23 @@ +/* + * Licensed to the Apache S

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

aloyszhang commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696099984 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/converter/TypeConverter.java: ## @@ -0,0 +1,23 @@ +/* + * Licensed to the Apache S

Re: [PR] [INLONG-10706][SDK] DataProxy SDK Shaded Native Library [inlong]

aloyszhang merged PR #10732: URL: https://github.com/apache/inlong/pull/10732 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

(inlong) branch master updated: [SDK] DataProxy SDK Shaded Native Library (#10732)

This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new d0f168886a [SDK] DataProxy SDK Shaded Native

Re: [PR] [INLONG-10728][Audit] Add global memory control for the Audit SDK [inlong]

dockerzhang merged PR #10733: URL: https://github.com/apache/inlong/pull/10733 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlon

(inlong) branch master updated: [INLONG-10728][Audit] Add global memory control for the Audit SDK (#10733)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/master by this push: new 381cbe5285 [INLONG-10728][Audit] Add global

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

luchunliang commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696155227 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/EsMapSinkEncoder.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

justinwwhuang commented on code in PR #10727: URL: https://github.com/apache/inlong/pull/10727#discussion_r1696164512 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java: ## @@ -54,60 +50,76 @@ private List splitSqlJob(String topics

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

luchunliang commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696168659 ## inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/DefaultEvent2IndexRequestHandler.java: ## @@ -1

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

justinwwhuang commented on code in PR #10727: URL: https://github.com/apache/inlong/pull/10727#discussion_r1696177032 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttReader.java: ## @@ -106,13 +107,13 @@ public void setUp() throws Excep

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

vernedeng commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696197041 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/EsMapSinkEncoder.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software F

Re: [PR] [INLONG-10703][Manager] Manager Add Oceanbase Support [inlong]

xxsc0529 commented on PR #10701: URL: https://github.com/apache/inlong/pull/10701#issuecomment-2257358769 > resolve Resolved -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific co

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

vernedeng commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696223185 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/EsMapSinkEncoder.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software F

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

vernedeng commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696224284 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/EsMapSinkEncoder.java: ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache Software F

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

vernedeng commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696226217 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/EsMapSinkInfo.java: ## @@ -0,0 +1,44 @@ +/* + * Licensed to the Apache Software Founda

Re: [PR] [INLONG-10729][Sort] Sorstandalone EsSink support transform [inlong]

vernedeng commented on code in PR #10734: URL: https://github.com/apache/inlong/pull/10734#discussion_r1696229852 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/converter/TypeConverter.java: ## @@ -0,0 +1,23 @@ +/* + * Licensed to the Apache So

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

qy-liuhuo commented on code in PR #10727: URL: https://github.com/apache/inlong/pull/10727#discussion_r1696284375 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttReader.java: ## @@ -106,13 +107,13 @@ public void setUp() throws Exception

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

justinwwhuang commented on code in PR #10727: URL: https://github.com/apache/inlong/pull/10727#discussion_r1696365462 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttReader.java: ## @@ -106,13 +107,13 @@ public void setUp() throws Excep

Re: [PR] [INLONG-10286][Agent] Update the MQTT Source [inlong]

qy-liuhuo commented on code in PR #10727: URL: https://github.com/apache/inlong/pull/10727#discussion_r1696366855 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestMqttReader.java: ## @@ -106,13 +107,13 @@ public void setUp() throws Exception

[PR] [INLONG-10289][Agent] Update the SQLServer Source [inlong]

zoy0 opened a new pull request, #10735: URL: https://github.com/apache/inlong/pull/10735 Fixes #10289 ### Motivation Update the SQLServer Source for agent ### Modifications Start a Debezium thread to collect change data from SQLServ