[GitHub] [inlong] EMsnap commented on a diff in pull request #6210: [INLONG-6174][Sort] Mysql connector support meta data with debezium format

EMsnap commented on code in PR #6210: URL: https://github.com/apache/inlong/pull/6210#discussion_r1000490064 ## inlong-common/src/main/java/org/apache/inlong/common/enums/MetaField.java: ## @@ -62,12 +62,22 @@ public enum MetaField { /** * Represents a canal json of a

[GitHub] [inlong] dockerzhang merged pull request #6237: [INLONG-6236][CVE] Fix the CVE-2022-42003 for jackson-databind

dockerzhang merged PR #6237: URL: https://github.com/apache/inlong/pull/6237 -- 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-6236][CVE] Fix the CVE-2022-42003 for jackson-databind (#6237)

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 7b40f0b10 [INLONG-6236][CVE] Fix the CVE-20

[GitHub] [inlong] healchow commented on a diff in pull request #6230: [INLONG-6216][Manager] Support get group topic info

healchow commented on code in PR #6230: URL: https://github.com/apache/inlong/pull/6230#discussion_r1000499024 ## inlong-manager/manager-dao/src/main/resources/mappers/InlongClusterEntityMapper.xml: ## @@ -247,4 +247,14 @@ where id = #{id,jdbcType=INTEGER} +

[GitHub] [inlong] healchow commented on a diff in pull request #6230: [INLONG-6216][Manager] Support get group topic info

healchow commented on code in PR #6230: URL: https://github.com/apache/inlong/pull/6230#discussion_r1000499307 ## inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongStreamExtEntityMapper.java: ## @@ -44,6 +44,9 @@ public interface InlongStreamExt

[GitHub] [inlong] healchow commented on a diff in pull request #6240: [INLONG-6239][InLong] Add inlongctl in the root directory

healchow commented on code in PR #6240: URL: https://github.com/apache/inlong/pull/6240#discussion_r1000380309 ## bin/inlongctl: ## @@ -0,0 +1,24 @@ +#! /bin/bash +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

[GitHub] [inlong] healchow commented on a diff in pull request #6240: [INLONG-6239][InLong] Add inlongctl in the root directory

healchow commented on code in PR #6240: URL: https://github.com/apache/inlong/pull/6240#discussion_r1000500877 ## bin/inlongctl: ## @@ -0,0 +1,25 @@ +#! /bin/bash +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6210: [INLONG-6174][Sort] Mysql connector support meta data with debezium format

yunqingmoswu commented on code in PR #6210: URL: https://github.com/apache/inlong/pull/6210#discussion_r1000527832 ## inlong-sort/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/table/MySqlReadableMetadata.java: ## @@ -98,7 +100,7 @@ public Object read(S

[GitHub] [inlong] thesumery opened a new pull request, #6247: [INLONG-6246][Sort] Import multiple sink option and schema update handle policy

thesumery opened a new pull request, #6247: URL: https://github.com/apache/inlong/pull/6247 [INLONG-6246][Sort] Import multiple sink option and schema update handle policy ### Prepare a Pull Request - Title Example: [INLONG-6246][Sort] Import multiple sink option and schema update

[GitHub] [inlong] EMsnap commented on a diff in pull request #6210: [INLONG-6174][Sort] Mysql connector support meta data with debezium format

EMsnap commented on code in PR #6210: URL: https://github.com/apache/inlong/pull/6210#discussion_r1000628573 ## inlong-sort/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/table/MySqlReadableMetadata.java: ## @@ -98,7 +100,7 @@ public Object read(SourceR

[GitHub] [inlong] EMsnap commented on a diff in pull request #6215: [INLONG-6214][Sort] Support multiple sink for IcebergLoadNode

EMsnap commented on code in PR #6215: URL: https://github.com/apache/inlong/pull/6215#discussion_r1000656733 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java: ## @@ -0,0 +1,395 @@ +/* + * Licensed t

[GitHub] [inlong] thesumery commented on a diff in pull request #6215: [INLONG-6214][Sort] Support multiple sink for IcebergLoadNode

thesumery commented on code in PR #6215: URL: https://github.com/apache/inlong/pull/6215#discussion_r1000718497 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java: ## @@ -0,0 +1,395 @@ +/* + * License

[GitHub] [inlong] thesumery commented on a diff in pull request #6215: [INLONG-6214][Sort] Support multiple sink for IcebergLoadNode

thesumery commented on code in PR #6215: URL: https://github.com/apache/inlong/pull/6215#discussion_r1000720450 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java: ## @@ -43,8 +66,39 @@ */ public abstract class Js

[GitHub] [inlong] dockerzhang merged pull request #6240: [INLONG-6239][InLong] Add inlongctl in the root directory

dockerzhang merged PR #6240: URL: https://github.com/apache/inlong/pull/6240 -- 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-6239][InLong] Add inlongctl in the root directory (#6240)

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 092e581c1 [INLONG-6239][InLong] Add inlongc

[GitHub] [inlong] healchow commented on a diff in pull request #6227: [INLONG-6226][Manager] Add a consumer group of TubeMQ for each sink

healchow commented on code in PR #6227: URL: https://github.com/apache/inlong/pull/6227#discussion_r1001287655 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQResourceOperator.java: ## @@ -66,24 +76,32 @@ public void

[GitHub] [inlong] healchow commented on a diff in pull request #6227: [INLONG-6226][Manager] Add a consumer group of TubeMQ for each sink

healchow commented on code in PR #6227: URL: https://github.com/apache/inlong/pull/6227#discussion_r1001287844 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQResourceOperator.java: ## @@ -66,24 +76,32 @@ public void

[GitHub] [inlong] healchow commented on a diff in pull request #6227: [INLONG-6226][Manager] Add a consumer group of TubeMQ for each sink

healchow commented on code in PR #6227: URL: https://github.com/apache/inlong/pull/6227#discussion_r1001287844 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQResourceOperator.java: ## @@ -66,24 +76,32 @@ public void

[GitHub] [inlong] healchow commented on a diff in pull request #6227: [INLONG-6226][Manager] Add a consumer group of TubeMQ for each sink

healchow commented on code in PR #6227: URL: https://github.com/apache/inlong/pull/6227#discussion_r1001288781 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQResourceOperator.java: ## @@ -66,24 +76,32 @@ public void

[GitHub] [inlong] healchow commented on a diff in pull request #6210: [INLONG-6174][Sort] Mysql connector support meta data with debezium format

healchow commented on code in PR #6210: URL: https://github.com/apache/inlong/pull/6210#discussion_r1001294560 ## inlong-sort/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/table/MySqlReadableMetadata.java: ## @@ -379,6 +415,38 @@ public Object read(Sou

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6247: [INLONG-6246][Sort] Import multiple sink option and schema update handle policy

yunqingmoswu commented on code in PR #6247: URL: https://github.com/apache/inlong/pull/6247#discussion_r1001295145 ## inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/sink/TableChange.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache Software F

[GitHub] [inlong] vernedeng commented on a diff in pull request #6227: [INLONG-6226][Manager] Add a consumer group of TubeMQ for each sink

vernedeng commented on code in PR #6227: URL: https://github.com/apache/inlong/pull/6227#discussion_r1001310721 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQResourceOperator.java: ## @@ -67,23 +83,31 @@ public void

[GitHub] [inlong] vernedeng commented on a diff in pull request #6227: [INLONG-6226][Manager] Add a consumer group of TubeMQ for each sink

vernedeng commented on code in PR #6227: URL: https://github.com/apache/inlong/pull/6227#discussion_r1001310721 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQResourceOperator.java: ## @@ -67,23 +83,31 @@ public void

[GitHub] [inlong] woofyzhao opened a new pull request, #6249: [INLONG-6248][Manager] Add sort status query plugin and api

woofyzhao opened a new pull request, #6249: URL: https://github.com/apache/inlong/pull/6249 - Fixes #6248 ### Motivation There are some pieces missing with regard to the overall inlong task management, for example - Sort job status is not known once after the sort jo

[GitHub] [inlong] vernedeng commented on a diff in pull request #6230: [INLONG-6216][Manager] Support get group topic info

vernedeng commented on code in PR #6230: URL: https://github.com/apache/inlong/pull/6230#discussion_r1001323113 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/ClusterBriefInfo.java: ## @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] vernedeng commented on a diff in pull request #6230: [INLONG-6216][Manager] Support get group topic info

vernedeng commented on code in PR #6230: URL: https://github.com/apache/inlong/pull/6230#discussion_r1001326498 ## inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterEntityMapper.java: ## @@ -57,4 +57,6 @@ List selectByKey(@Param("clusterT

[GitHub] [inlong] vernedeng commented on a diff in pull request #6230: [INLONG-6216][Manager] Support get group topic info

vernedeng commented on code in PR #6230: URL: https://github.com/apache/inlong/pull/6230#discussion_r1001326594 ## inlong-manager/manager-dao/src/main/resources/mappers/InlongClusterEntityMapper.xml: ## @@ -247,4 +247,14 @@ where id = #{id,jdbcType=INTEGER} +

[GitHub] [inlong] GanfengTan opened a new pull request, #6252: [INLONG-6251][Agent] Fix UT ConcurrentModification error

GanfengTan opened a new pull request, #6252: URL: https://github.com/apache/inlong/pull/6252 Fix ConcurrentModification error when TestFileAgent UT - Fixes #6251 ### Motivation Run TestFIle UT error, change ArrayList to CopyOnWriteArrayList. ### Modifications

[GitHub] [inlong] thesumery commented on a diff in pull request #6215: [INLONG-6214][Sort] Support multiple sink for IcebergLoadNode

thesumery commented on code in PR #6215: URL: https://github.com/apache/inlong/pull/6215#discussion_r1001429267 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/WholeDatabaseMigrationOperator.java: ## @@ -0,0 +1,228 @@ +/* + * Li

[GitHub] [inlong] dockerzhang opened a new pull request, #6237: [INLONG-6236][CVE] Fix the CVE-2022-42003 for jackson-databind

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

[GitHub] [inlong] dockerzhang commented on pull request #5989: [INLONG-5043][Manager] Add Apache Doris load node management

dockerzhang commented on PR #5989: URL: https://github.com/apache/inlong/pull/5989#issuecomment-1285060746 duplicated with https://github.com/apache/inlong/pull/6233, close it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [inlong] dockerzhang closed pull request #5989: [INLONG-5043][Manager] Add Apache Doris load node management

dockerzhang closed pull request #5989: [INLONG-5043][Manager] Add Apache Doris load node management URL: https://github.com/apache/inlong/pull/5989 -- 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 th

[GitHub] [inlong] healchow merged pull request #6221: [INLONG-6220][Manager] Support query cluster nodes by the manager client

healchow merged PR #6221: URL: https://github.com/apache/inlong/pull/6221 -- 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 (ebf93ef09 -> 5be8d1795)

This is an automated email from the ASF dual-hosted git repository. healchow pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from ebf93ef09 [INLONG-6234][DataProxy] Adjust the source report information acquisition source (#6235) add 5be8d17

[GitHub] [inlong] GanfengTan commented on issue #6186: [Umbrella] Support node protocol reporting and query

GanfengTan commented on issue #6186: URL: https://github.com/apache/inlong/issues/6186#issuecomment-1285069779 All functions are supported. -- 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 spe

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6215: [INLONG-6214][Sort] Support multiple sink for IcebergLoadNode

yunqingmoswu commented on code in PR #6215: URL: https://github.com/apache/inlong/pull/6215#discussion_r1000226942 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergMultipleStreamWriter.java: ## @@ -0,0 +1,227 @@ +/* + * Li

[GitHub] [inlong-website] gosonzhang opened a new pull request, #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

gosonzhang opened a new pull request, #571: URL: https://github.com/apache/inlong-website/pull/571 - Fixes : https://github.com/apache/inlong/issues/6238 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [inlong-website] healchow commented on a diff in pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

healchow commented on code in PR #571: URL: https://github.com/apache/inlong-website/pull/571#discussion_r1000263529 ## docs/modules/dataproxy/configuration.md: ## @@ -0,0 +1,50 @@ +--- +title: Configuration +sidebar_position: 3 +--- +## Basic Configuration (common.properties) +

[GitHub] [inlong-website] gosonzhang commented on a diff in pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

gosonzhang commented on code in PR #571: URL: https://github.com/apache/inlong-website/pull/571#discussion_r1000267545 ## docs/modules/dataproxy/configuration.md: ## @@ -0,0 +1,50 @@ +--- +title: Configuration +sidebar_position: 3 +--- +## Basic Configuration (common.properties)

[GitHub] [inlong-website] dockerzhang commented on a diff in pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

dockerzhang commented on code in PR #571: URL: https://github.com/apache/inlong-website/pull/571#discussion_r1000273876 ## i18n/zh-CN/docusaurus-plugin-content-docs/current/modules/dataproxy/configuration.md: ## @@ -0,0 +1,52 @@ +--- +title: 配置 +sidebar_position: 3 +--- + +## 基本

[GitHub] [inlong-website] healchow commented on a diff in pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

healchow commented on code in PR #571: URL: https://github.com/apache/inlong-website/pull/571#discussion_r1000290536 ## i18n/zh-CN/docusaurus-plugin-content-docs/current/modules/dataproxy/configuration.md: ## @@ -0,0 +1,52 @@ +--- +title: 配置 +sidebar_position: 3 +--- + +## 基本配置（

[GitHub] [inlong-website] healchow commented on a diff in pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

healchow commented on code in PR #571: URL: https://github.com/apache/inlong-website/pull/571#discussion_r1000292138 ## i18n/zh-CN/docusaurus-plugin-content-docs/current/modules/dataproxy/configuration.md: ## @@ -0,0 +1,52 @@ +--- +title: 配置 +sidebar_position: 3 +--- + +## 基本配置（

[GitHub] [inlong-website] healchow commented on a diff in pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

healchow commented on code in PR #571: URL: https://github.com/apache/inlong-website/pull/571#discussion_r1000294768 ## i18n/zh-CN/docusaurus-plugin-content-docs/current/modules/dataproxy/configuration.md: ## @@ -0,0 +1,52 @@ +--- +title: 配置 +sidebar_position: 3 +--- + +## 基本配置（

[GitHub] [inlong] haifxu opened a new pull request, #6240: [INLONG-6239][Manager] Add inlongctl in the root directory

haifxu opened a new pull request, #6240: URL: https://github.com/apache/inlong/pull/6240 ### Prepare a Pull Request - Fixes #6239 ### Modifications Add `bin/inlongctl` in the root directory to execute `inlong-manager/bin/managerctl` -- This is an automated messag

[GitHub] [inlong] lucaspeng12138 opened a new pull request, #6242: [INLONG-6241][Docker] Add manager and audit database table configuration

lucaspeng12138 opened a new pull request, #6242: URL: https://github.com/apache/inlong/pull/6242 ### Prepare a Pull Request Add manager and audit database table configuration - Fixes #6241 ### Motivation Add manager and audit database table configuration ### Mo

[GitHub] [inlong] healchow commented on a diff in pull request #6240: [INLONG-6239][InLong] Add inlongctl in the root directory

healchow commented on code in PR #6240: URL: https://github.com/apache/inlong/pull/6240#discussion_r1000376108 ## bin/inlongctl: ## @@ -0,0 +1,25 @@ +#! /bin/bash +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

[GitHub] [inlong] healchow commented on a diff in pull request #6240: [INLONG-6239][InLong] Add inlongctl in the root directory

healchow commented on code in PR #6240: URL: https://github.com/apache/inlong/pull/6240#discussion_r1000380309 ## bin/inlongctl: ## @@ -0,0 +1,24 @@ +#! /bin/bash +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the

[GitHub] [inlong] yunqingmoswu opened a new pull request, #6244: [INLONG-6243][Sort] Add custom name for sort job

yunqingmoswu opened a new pull request, #6244: URL: https://github.com/apache/inlong/pull/6244 ### Prepare a Pull Request *(Change the title refer to the following example)* Title: [INLONG-6243][Sort] Add custom name for sort job *(The following *XYZ* should be replaced by th

[GitHub] [inlong] EMsnap commented on a diff in pull request #6244: [INLONG-6243][Sort] Add custom name for sort job

EMsnap commented on code in PR #6244: URL: https://github.com/apache/inlong/pull/6244#discussion_r1000413351 ## inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java: ## @@ -52,6 +52,7 @@ public static void main(String[] args) throws Exception { Envir

[GitHub] [inlong] haibo-duan opened a new pull request, #6245: [INLONG-4986][Agent] Support MQTT Source

haibo-duan opened a new pull request, #6245: URL: https://github.com/apache/inlong/pull/6245 ### 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 repla

[GitHub] [inlong] dockerzhang merged pull request #6242: [INLONG-6241][Docker] Add manager and audit database name configuration

dockerzhang merged PR #6242: URL: https://github.com/apache/inlong/pull/6242 -- 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-6241][Docker] Add manager and audit database name configuration (#6242)

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 055bd93dd [INLONG-6241][Docker] Add manager

[GitHub] [inlong-website] dockerzhang merged pull request #571: [INLONG-6238][Doc] Add configuration doc for DataProxy

dockerzhang merged PR #571: URL: https://github.com/apache/inlong-website/pull/571 -- 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...@i

[inlong-website] branch master updated: [INLONG-6238][Doc] Add configuration doc for DataProxy (#571)

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-website.git The following commit(s) were added to refs/heads/master by this push: new 3953f07a4c [INLONG-6238][Doc] Add c