Re: [PR] [INLONG-10644][Sort] Add the elasticsearch-base module to implement elasticsearch connector 6&7 [inlong]

XiaoYou201 commented on code in PR #10647: URL: https://github.com/apache/inlong/pull/10647#discussion_r1689236611 ## licenses/inlong-sort-connectors/LICENSE: ## @@ -935,6 +935,28 @@ License : https://github.com/ververica/flink-cdc-connectors/blob/master/LICENSE Source : org.

Re: [PR] [INLONG-10644][Sort] Add the elasticsearch-base module to implement elasticsearch connector 6&7 [inlong]

XiaoYou201 commented on PR #10647: URL: https://github.com/apache/inlong/pull/10647#issuecomment-2247021112 > Plz add source information for es connector classes The es connector 6/7 are base on it. So,in my opinion, it is also a part of es connector. -- This is an automated messag

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

xxsc0529 commented on code in PR #10701: URL: https://github.com/apache/inlong/pull/10701#discussion_r1689193253 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java: ## @@ -0,0 +1,276 @@ +/* + * Licens

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689188362 ## inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache

(inlong) branch branch-1.13 updated: [INLONG-10662][Release] Change the tag of Docker images to 1.13.0 (#10713)

This is an automated email from the ASF dual-hosted git repository. wakefu pushed a commit to branch branch-1.13 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/branch-1.13 by this push: new d01ef8dcd5 [INLONG-10662][Release] Cha

Re: [PR] [INLONG-10662][Release] Change the tag of Docker images to 1.13.0 [inlong]

fuweng11 merged PR #10713: URL: https://github.com/apache/inlong/pull/10713 -- 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.a

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689185398 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java: ## @@ -0,0 +1,244 @@ +/* + *

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689186281 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialectFactory.java: ## Review Comment:

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689184031 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java: ## @@ -0,0 +1,244 @@ +/* + *

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689183278 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialectFactory.java: ## @@ -0,0 +1,31 @@ +/

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689176575 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java: ## @@ -0,0 +1,244 @@ +/* + *

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

xxsc0529 commented on PR #10701: URL: https://github.com/apache/inlong/pull/10701#issuecomment-2246955944 > please add test result with real data from any source to oceanbase What kind of test data is needed and where to put it -- This is an automated message from the Apache Git Service

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on PR #10700: URL: https://github.com/apache/inlong/pull/10700#issuecomment-2246954120 > please add test result with real data from any source to oceanbase What kind of test data is needed and where to put it -- This is an automated message from the Apache Git Ser

Re: [I] [Release] Create a 1.13.0 branch to release [inlong]

aloyszhang commented on issue #10659: URL: https://github.com/apache/inlong/issues/10659#issuecomment-2246832718 https://github.com/apache/inlong/tree/branch-1.13 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [I] [Release] Publish all 1.13.0 images to docker hub [inlong]

fuweng11 commented on issue #10663: URL: https://github.com/apache/inlong/issues/10663#issuecomment-2246803521 https://github.com/user-attachments/assets/c3fc448c-9bcb-418a-a79b-2f42035ea1fd";> -- This is an automated message from the Apache Git Service. To respond to the message, plea

[PR] [INLONG-10662][Release] Change the tag of Docker images to 1.13.0 [inlong]

fuweng11 opened a new pull request, #10713: URL: https://github.com/apache/inlong/pull/10713 Fixes #10662 ### Motivation Change the tag of Docker images to 1.13.0. ### Modifications Change the tag of Docker images to 1.13.0. -- This is an aut

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689058825 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java: ## @@ -0,0 +1,244 @@ +/* +

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689058944 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java: ## @@ -0,0 +1,244 @@ +/* +

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689057755 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialect.java: ## @@ -0,0 +1,244 @@ +/* +

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689055233 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialectFactory.java: ## @@ -0,0 +1,31 @@

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689054104 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/jdbc/JdbcDialectFactory.java: ## Review Comment:

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

EMsnap commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1689051827 ## inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/MySqlExtractNodeToOceanBaseLoadNodeTest.java: ## @@ -0,0 +1,138 @@ +/* + * Licensed to the Apache S

Re: [PR] [INLONG-10632][Dashboard] Dashboard Add Oceanbase Support [inlong]

dockerzhang merged PR #10698: URL: https://github.com/apache/inlong/pull/10698 -- 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-10632][Dashboard] Dashboard Add Oceanbase Support (#10698)

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 4425586894 [INLONG-10632][Dashboard] Dashbo

(inlong) branch branch-1.13 updated: [INLONG-10661][Release] Bumped 1.13.0 branch version to 1.13.0 (#10708)

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

Re: [PR] [INLONG-10661][Release] Bumped 1.13.0 branch version to 1.13.0 [inlong]

aloyszhang merged PR #10708: URL: https://github.com/apache/inlong/pull/10708 -- 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

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

xxsc0529 commented on code in PR #10701: URL: https://github.com/apache/inlong/pull/10701#discussion_r1689032407 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/OfflineJobSubmitRequest.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-10660][Release] Bumped master branch version to 1.14.0-SNAPSHOT [inlong]

dockerzhang merged PR #10707: URL: https://github.com/apache/inlong/pull/10707 -- 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-10660][Release] Bumped master branch version to 1.14.0-SNAPSHOT (#10707)

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 aa6896a02c [INLONG-10660][Release] Bumped m

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

vernedeng commented on code in PR #10701: URL: https://github.com/apache/inlong/pull/10701#discussion_r1689011164 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java: ## @@ -0,0 +1,276 @@ +/* + * Licen

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

fuweng11 commented on code in PR #10701: URL: https://github.com/apache/inlong/pull/10701#discussion_r1689009434 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/OfflineJobSubmitRequest.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache

(inlong) branch branch-1.13 updated: [INLONG-10711][Manager] Fix the problem of the stream source did not update its status correctly after executing the workflow (#10712)

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

(inlong) branch master updated: [INLONG-10711][Manager] Fix the problem of the stream source did not update its status correctly after executing the workflow (#10712)

This is an automated email from the ASF dual-hosted git repository. wakefu 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 93e9a32151 [INLONG-10711][Manager] Fix the probl

Re: [PR] [INLONG-10711][Manager] Fix the problem of the stream source did not update its status correctly after executing the workflow [inlong]

fuweng11 merged PR #10712: URL: https://github.com/apache/inlong/pull/10712 -- 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.a

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

xxsc0529 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1688989272 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/OceanBaseExtractNode.java: ## @@ -0,0 +1,336 @@ +/* + * Licensed to the Apache S

[PR] [INLONG-10711][Release] Fix the problem of the stream source did not update its status correctly after executing the workflow [inlong]

fuweng11 opened a new pull request, #10712: URL: https://github.com/apache/inlong/pull/10712 Fixes #10711 ### Motivation Fix the problem of the stream source did not update its status correctly after executing the workflow. ### Modifications Fi

(inlong) branch branch-1.13 updated: [INLONG-10709][Manager] fix group exist check error caused by schedule configuration (#10710)

This is an automated email from the ASF dual-hosted git repository. wakefu pushed a commit to branch branch-1.13 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/branch-1.13 by this push: new 29948c0a6d [INLONG-10709][Manager] fix

(inlong) branch master updated: [INLONG-10709][Manager] fix group exist check error caused by schedule configuration (#10710)

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 35c72c136d [INLONG-10709][Manager] fix group

Re: [PR] [INLONG-10709][Manager] fix group exist check error caused by schedule configuration [inlong]

aloyszhang merged PR #10710: URL: https://github.com/apache/inlong/pull/10710 -- 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

[PR] [INLONG-10709][Manager] fix group exist check error caused by schedule configuration [inlong]

aloyszhang opened a new pull request, #10710: URL: https://github.com/apache/inlong/pull/10710 Fixes #10709 ### Motivation when checking group exists, there is a bug caused by schedule configurations. ### Modifications fix group existing check error caused

Re: [PR] [INLONG-10704][Sort] Sort Add Oceanbase Support [inlong]

vernedeng commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1687828964 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/OceanBaseExtractNode.java: ## @@ -0,0 +1,336 @@ +/* + * Licensed to the Apache

Re: [I] [Improve][Agent] Update the MQTT Source [inlong]

2063625785 commented on issue #10286: URL: https://github.com/apache/inlong/issues/10286#issuecomment-2244808396 Successfully claimed this issue -- 原始邮件 -- 发件人:

Re: [I] 【咨询】iceberg sink新增列 [inlong]

vernedeng commented on issue #10699: URL: https://github.com/apache/inlong/issues/10699#issuecomment-2244789583 > flink iceberg sink, 如果sink table运营中新增列，是否需要重启任务，如果不重启，项目如何实现处理该场景 better to write an issues in English. -- This is an automated message from the Apache Git Service. To r

Re: [I] [Improve][Agent] Update the MQTT Source [inlong]

qy-liuhuo commented on issue #10286: URL: https://github.com/apache/inlong/issues/10286#issuecomment-2244634675 Successfully claimed this issue -- 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

Re: [PR] [INLONG-10684][SDK] Inlong transform supports context [inlong]

vernedeng merged PR #10702: URL: https://github.com/apache/inlong/pull/10702 -- 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-10684][SDK] Inlong transform supports context (#10702)

This is an automated email from the ASF dual-hosted git repository. vernedeng 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 1518021802 [INLONG-10684][SDK] Inlong transfo

[PR] [INLONG-10661][Release] Bumped 1.13.0 branch version to 1.13.0 [inlong]

fuweng11 opened a new pull request, #10708: URL: https://github.com/apache/inlong/pull/10708 Fixes #10661 ### Motivation Bumped 1.13.0 branch version to 1.13.0. ### Modifications Bumped 1.13.0 branch version to 1.13.0. -- This is an automated

(inlong) branch master updated: [INLONG-10658][Release] Update changes log for the 1.13.0 version (#10673)

This is an automated email from the ASF dual-hosted git repository. wakefu 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 dfd5ccc2f5 [INLONG-10658][Release] Update change

Re: [PR] [INLONG-10658][Release] Update changes log for the 1.13.0 version [inlong]

fuweng11 merged PR #10673: URL: https://github.com/apache/inlong/pull/10673 -- 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.a

[PR] [INLONG-10660][Release] Bumped master branch version to 1.14.0-SNAPSHOT [inlong]

fuweng11 opened a new pull request, #10707: URL: https://github.com/apache/inlong/pull/10707 Fixes #10660 ### Motivation Bumped master branch version to 1.14.0-SNAPSHOT. ### Modifications Bumped master branch version to 1.14.0-SNAPSHOT. -- Th

(inlong) branch branch-1.13 created (now dfd5ccc2f5)

This is an automated email from the ASF dual-hosted git repository. wakefu pushed a change to branch branch-1.13 in repository https://gitbox.apache.org/repos/asf/inlong.git at dfd5ccc2f5 [INLONG-10658][Release] Update changes log for the 1.13.0 version (#10673) No new revisions were add