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

2024-07-24 Thread via GitHub
XiaoYou201 commented on PR #10647: URL: https://github.com/apache/inlong/pull/10647#issuecomment-2247113634 > Please add test result on es 6 or 7 As follow image, I implement es 6 connector and postgreSQL to ElasticSearch6 test successfully . But es6 base on this pr, so, the es6 connect

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

2024-07-24 Thread via GitHub
aloyszhang commented on code in PR #10647: URL: https://github.com/apache/inlong/pull/10647#discussion_r1689426722 ## licenses/inlong-sort-connectors/LICENSE: ## @@ -938,6 +938,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]

2024-07-24 Thread via GitHub
aloyszhang commented on code in PR #10647: URL: https://github.com/apache/inlong/pull/10647#discussion_r1689426722 ## licenses/inlong-sort-connectors/LICENSE: ## @@ -938,6 +938,28 @@ License : https://github.com/ververica/flink-cdc-connectors/blob/master/LICENSE Source : org.

[PR] [INLONG-10714][Manager] Fix the problem of incorrect deletion of data source task [inlong]

2024-07-24 Thread via GitHub
fuweng11 opened a new pull request, #10715: URL: https://github.com/apache/inlong/pull/10715 Fixes #10714 ### Motivation Fix the problem of incorrect deletion of data source task. ### Modifications Fix the problem of incorrect deletion of da

[PR] [INLONG-10716][SDK] Inlong Transform usage optimization [inlong]

2024-07-24 Thread via GitHub
vernedeng opened a new pull request, #10717: URL: https://github.com/apache/inlong/pull/10717 Fixes #10716 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This

Re: [PR] [INLONG-10716][SDK] Inlong Transform usage optimization [inlong]

2024-07-24 Thread via GitHub
aloyszhang commented on code in PR #10717: URL: https://github.com/apache/inlong/pull/10717#discussion_r1689524909 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/CsvSourceInfo.java: ## @@ -28,17 +29,18 @@ * CsvSourceInfo */ @JsonIgnorePropert

Re: [PR] [INLONG-10716][SDK] Inlong Transform usage optimization [inlong]

2024-07-24 Thread via GitHub
aloyszhang commented on code in PR #10717: URL: https://github.com/apache/inlong/pull/10717#discussion_r1689525564 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/CsvSinkInfo.java: ## @@ -30,15 +30,15 @@ @JsonIgnoreProperties(ignoreUnknown = true)

Re: [PR] [INLONG-10716][SDK] Inlong Transform usage optimization [inlong]

2024-07-24 Thread via GitHub
aloyszhang commented on code in PR #10717: URL: https://github.com/apache/inlong/pull/10717#discussion_r1689526655 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/KvSourceInfo.java: ## @@ -28,8 +30,15 @@ * KvSourceInfo */ @JsonIgnoreProperties

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

2024-07-24 Thread via GitHub
aloyszhang commented on PR #10647: URL: https://github.com/apache/inlong/pull/10647#issuecomment-2247552859 Flink-1.15 needs this feature too, would you like to work on it? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

Re: [PR] [INLONG-10716][SDK] Inlong Transform usage optimization [inlong]

2024-07-24 Thread via GitHub
vernedeng commented on code in PR #10717: URL: https://github.com/apache/inlong/pull/10717#discussion_r1689603608 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/CsvSourceInfo.java: ## @@ -28,17 +29,18 @@ * CsvSourceInfo */ @JsonIgnoreProperti

Re: [PR] [INLONG-10714][Manager] Fix the problem of incorrect deletion of data source task [inlong]

2024-07-24 Thread via GitHub
fuweng11 merged PR #10715: URL: https://github.com/apache/inlong/pull/10715 -- 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

(inlong) branch branch-1.13 updated: [INLONG-10714][Manager] Fix the problem of incorrect deletion of data source task (#10715)

2024-07-24 Thread wakefu
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 ecfae06b9c [INLONG-10714][Manager] Fix

(inlong) branch master updated (4425586894 -> cba6abd8a0)

2024-07-24 Thread wakefu
This is an automated email from the ASF dual-hosted git repository. wakefu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 4425586894 [INLONG-10632][Dashboard] Dashboard Add Oceanbase Support (#10698) add cba6abd8a0 [INLONG-10714][Mana

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

2024-07-24 Thread via GitHub
XiaoYou201 commented on PR #10647: URL: https://github.com/apache/inlong/pull/10647#issuecomment-2247681190 > BTW, Flink-1.15 needs this feature too, would you like to work on it? yes, I would like to do that, it will done soon~ -- This is an automated message from the Apache Git Se

Re: [PR] [INLONG-10716][SDK] Inlong Transform usage optimization [inlong]

2024-07-24 Thread via GitHub
aloyszhang merged PR #10717: URL: https://github.com/apache/inlong/pull/10717 -- 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 (cba6abd8a0 -> a4e688171d)

2024-07-24 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from cba6abd8a0 [INLONG-10714][Manager] Fix the problem of incorrect deletion of data source task (#10715) add a4

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

2024-07-24 Thread via GitHub
EMsnap merged PR #10647: URL: https://github.com/apache/inlong/pull/10647 -- 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.apa

(inlong) branch master updated: [INLONG-10644][Sort] Add the elasticsearch-base module to implement elasticsearch connector 6&7 (#10647)

2024-07-24 Thread zirui
This is an automated email from the ASF dual-hosted git repository. zirui 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 2d487362d5 [INLONG-10644][Sort] Add the elasticse

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

2024-07-24 Thread via GitHub
XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1690876562 ## 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]

2024-07-24 Thread via GitHub
XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1690877425 ## 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]

2024-07-24 Thread via GitHub
XiaoYou201 commented on code in PR #10700: URL: https://github.com/apache/inlong/pull/10700#discussion_r1690880917 ## 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]

2024-07-24 Thread via GitHub
XiaoYou201 commented on PR #10700: URL: https://github.com/apache/inlong/pull/10700#issuecomment-2249561835 > > please add test result with real data from any source to oceanbase > > What kind of test data is needed and where to put it You can refer to inlong-sort/sort-end-to-e