[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6175: [INLONG-6045][Sort] Support all migrate for Oracle connector

yunqingmoswu commented on code in PR #6175: URL: https://github.com/apache/inlong/pull/6175#discussion_r1002938240 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/Metadata.java: ## @@ -54,6 +54,10 @@ default String getMetadataKey(MetaField metaField) {

[GitHub] [inlong] e-mhui commented on a diff in pull request #6175: [INLONG-6045][Sort] Support all migrate for Oracle connector

e-mhui commented on code in PR #6175: URL: https://github.com/apache/inlong/pull/6175#discussion_r1002965623 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/Metadata.java: ## @@ -54,6 +54,10 @@ default String getMetadataKey(MetaField metaField) {

[GitHub] [inlong] yunqingmoswu closed pull request #6213: [INLONG-6212][Sort] Support multiple sink for DorisLoadNode

yunqingmoswu closed pull request #6213: [INLONG-6212][Sort] Support multiple sink for DorisLoadNode URL: https://github.com/apache/inlong/pull/6213 -- 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] EMsnap commented on a diff in pull request #6247: [INLONG-6246][Sort] Import multiple sink option and schema update handle policy

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

[GitHub] [inlong-website] doleyzi opened a new issue, #574: [Improve][Audit]Update configuration item description

doleyzi opened a new issue, #574: URL: https://github.com/apache/inlong-website/issues/574 ### Description Update configuration item description ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to fo

[GitHub] [inlong-website] doleyzi opened a new pull request, #575: [INLONG-574][Audit]Update configuration item description

doleyzi opened a new pull request, #575: URL: https://github.com/apache/inlong-website/pull/575 ### Prepare a Pull Request - [INLONG-574][Audit]Update configuration item description - Fixes #574 ### Motivation Update configuration item description -- This is an auto

[GitHub] [inlong] EMsnap merged pull request #6247: [INLONG-6246][Sort] Import multiple sink option and schema update handle policy

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

[inlong] branch master updated (6af44eec2 -> 91615d40f)

This is an automated email from the ASF dual-hosted git repository. zirui pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 6af44eec2 [INLONG-6268][Manager] Support raw format for Load nodes (#6269) add 91615d40f [INLONG-6246][Sort] Impo

[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_r1003192882 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergMultipleStreamWriter.java: ## @@ -0,0 +1,227 @@ +/* + * Licen

[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_r1003201193 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/WholeDatabaseMigrationOperator.java: ## @@ -0,0 +1,228 @@ +/* + * Li

[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_r1003201417 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/WholeDatabaseMigrationOperator.java: ## @@ -0,0 +1,228 @@ +/* + * Li

[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_r1003202096 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/WholeDatabaseMigrationOperator.java: ## @@ -0,0 +1,228 @@ +/* + * Li

[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_r1003207476 ## 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 opened a new pull request, #6272: [INLONG-6271][Sort] Unhandled update_before data in canal json in multiple sink scene

thesumery opened a new pull request, #6272: URL: https://github.com/apache/inlong/pull/6272 [INLONG-6271][Sort] Unhandled update_before data in canal json in multiple sink scene ### Prepare a Pull Request - [INLONG-6271][Sort] Unhandled update_before data in canal json in multi

[GitHub] [inlong] healchow merged pull request #6230: [INLONG-6216][Manager] Support getting group topic info

healchow merged PR #6230: URL: https://github.com/apache/inlong/pull/6230 -- 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-6216][Manager] Support getting group topic info (#6230)

This is an automated email from the ASF dual-hosted git repository. healchow 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 d8cdae17d [INLONG-6216][Manager] Support getti

[GitHub] [inlong] github-actions[bot] commented on issue #5708: [Feature][DataProxy] Provide single flume channel to reduce synchronized operation, and improve DataProxy performance.

github-actions[bot] commented on issue #5708: URL: https://github.com/apache/inlong/issues/5708#issuecomment-1289885582 This issue is stale because it has been open for 60 days with no activity. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [inlong] github-actions[bot] commented on issue #5511: [Feature][SortSdk] Support multi-topic fetcher

github-actions[bot] commented on issue #5511: URL: https://github.com/apache/inlong/issues/5511#issuecomment-1289885640 This issue is stale because it has been open for 60 days with no activity. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [inlong] github-actions[bot] commented on issue #4973: [Umbrella][Manager] Supplement the Managerctl Commands Tools

github-actions[bot] commented on issue #4973: URL: https://github.com/apache/inlong/issues/4973#issuecomment-1289885775 This issue is stale because it has been open for 60 days with no activity. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [inlong] dockerzhang commented on pull request #6203: [INLONG-6176][Agent] Support collect data from Oracle

dockerzhang commented on PR #6203: URL: https://github.com/apache/inlong/pull/6203#issuecomment-1289905025 @haibo-duan here we need to add Oracle Source to the JobProfileDto.class. You can refer to MongoDB at https://github.com/apache/inlong/pull/5674. maybe other sources you added in

[GitHub] [inlong] healchow commented on a diff in pull request #6260: [INLONG-6258][Dashboard] Source data delimiter changed from ASCII to symbol

healchow commented on code in PR #6260: URL: https://github.com/apache/inlong/pull/6260#discussion_r1003946795 ## inlong-dashboard/src/metas/stream/index.tsx: ## @@ -142,27 +142,27 @@ const fieldsDefault: FieldItemType[] = [ options: [ { label: i18n.t(

[GitHub] [inlong] Oneal65 closed pull request #6205: [INLONG-6204][Agent] Support HeartbeatManager and TaskPositionManager for DBSync

Oneal65 closed pull request #6205: [INLONG-6204][Agent] Support HeartbeatManager and TaskPositionManager for DBSync URL: https://github.com/apache/inlong/pull/6205 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[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_r1003953224 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/WholeDatabaseMigrationOperator.java: ## @@ -0,0 +1,228 @@ +/* + *

[GitHub] [inlong] healchow commented on pull request #6260: [INLONG-6258][Dashboard] Source data delimiter changed from ASCII to symbol

healchow commented on PR #6260: URL: https://github.com/apache/inlong/pull/6260#issuecomment-1289916898 Keep the usage of ASCII for data separators. -- 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 t

[GitHub] [inlong] healchow closed pull request #6260: [INLONG-6258][Dashboard] Source data delimiter changed from ASCII to symbol

healchow closed pull request #6260: [INLONG-6258][Dashboard] Source data delimiter changed from ASCII to symbol URL: https://github.com/apache/inlong/pull/6260 -- 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

[GitHub] [inlong] healchow commented on issue #6258: [Improve][Dashboard] Source data delimiter changed from ASCII to symbol

healchow commented on issue #6258: URL: https://github.com/apache/inlong/issues/6258#issuecomment-1289917371 Keep the usage of ASCII for data separators, the backend does the transfer operation when needed. -- This is an automated message from the Apache Git Service. To respond to the mes

[GitHub] [inlong] EMsnap commented on a diff in pull request #6245: [INLONG-4986][Agent] Support MQTT Source

EMsnap commented on code in PR #6245: URL: https://github.com/apache/inlong/pull/6245#discussion_r1003955955 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java: ## @@ -0,0 +1,222 @@ +/* + * Licensed to the Apache Software Fo

[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_r1003959521 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/SchemaChangeUtils.java: ## @@ -0,0 +1,137 @@ +/* + * Licensed to the Ap

[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_r1003959924 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/SchemaChangeUtils.java: ## @@ -0,0 +1,137 @@ +/* + * Licensed to the Ap

[GitHub] [inlong] vernedeng opened a new pull request, #6275: [INLONG-6104][Manager] Refator getSortSource

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

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6213: [INLONG-6212][Sort] Support multiple sink for DorisLoadNode

yunqingmoswu commented on code in PR #6213: URL: https://github.com/apache/inlong/pull/6213#discussion_r1004046989 ## inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java: ## @@ -0,0 +1,337 @@ +/* + * Licensed to

[GitHub] [inlong] thesumery commented on pull request #6213: [INLONG-6212][Sort] Support multiple sink for DorisLoadNode

thesumery commented on PR #6213: URL: https://github.com/apache/inlong/pull/6213#issuecomment-1290050136 Add license for copied code -- 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 c

[GitHub] [inlong] pocozh commented on a diff in pull request #6245: [INLONG-4986][Agent] Support MQTT Source

pocozh commented on code in PR #6245: URL: https://github.com/apache/inlong/pull/6245#discussion_r1004057448 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java: ## @@ -0,0 +1,222 @@ +/* + * Licensed to the Apache Software Fo

[GitHub] [inlong] yunqingmoswu commented on pull request #6213: [INLONG-6212][Sort] Support multiple sink for DorisLoadNode

yunqingmoswu commented on PR #6213: URL: https://github.com/apache/inlong/pull/6213#issuecomment-1290071396 > Add license for copied code Thanks, done. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo