[GitHub] [inlong] bluewang opened a new pull request, #6687: [INLONG-6652][Manager] Support MQTT source

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

[GitHub] [inlong] yunqingmoswu opened a new pull request, #6688: [INLONG-6671][Sort] Supports dirty data side-output for kafka connector

yunqingmoswu opened a new pull request, #6688: URL: https://github.com/apache/inlong/pull/6688 ### Prepare a Pull Request *(Change the title refer to the following example)* - Title: [INLONG-6671][Sort] Supports dirty data side-output for kafka connector *(The following *XYZ

[GitHub] [inlong] wangpeix commented on a diff in pull request #6684: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter

wangpeix commented on code in PR #6684: URL: https://github.com/apache/inlong/pull/6684#discussion_r1035841169 ## inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java: ## @@ -58,7 +58,8 @@ public static void main(String[] args) throws Exception { Par

[GitHub] [inlong] EMsnap commented on a diff in pull request #6688: [INLONG-6671][Sort] Supports dirty data side-output for kafka connector

EMsnap commented on code in PR #6688: URL: https://github.com/apache/inlong/pull/6688#discussion_r1035862494 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java: ## @@ -149,6 +171,35 @@ public void deserial

[GitHub] [inlong] Yizhou-Yang opened a new pull request, #6691: [INLONG-6690] doris multiple sink migration throws exception at enable batch delete

Yizhou-Yang opened a new pull request, #6691: URL: https://github.com/apache/inlong/pull/6691 ### 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 merged pull request #6686: [INLONG-6685][Script] The bin/init-config.sh script compatible with MacOS

dockerzhang merged PR #6686: URL: https://github.com/apache/inlong/pull/6686 -- 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 (2de3cd863 -> 2c4abebd3)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 2de3cd863 [INLONG-6680][Dashboard] Set the plugin to default when there is no target plugin (#6682) add 2c4

[GitHub] [inlong] dockerzhang merged pull request #6679: [INLONG-6678][Dashboard] Add sinkType parameter in sinkFieldList

dockerzhang merged PR #6679: URL: https://github.com/apache/inlong/pull/6679 -- 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 (2c4abebd3 -> 0671c3a45)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 2c4abebd3 [INLONG-6685][Script] The bin/init-config.sh script compatible with MacOS (#6686) add 0671c3a45 [

[GitHub] [inlong] wangpeix closed pull request #6684: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter

wangpeix closed pull request #6684: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter URL: https://github.com/apache/inlong/pull/6684 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6688: [INLONG-6671][Sort] Supports dirty data side-output for kafka connector

yunqingmoswu commented on code in PR #6688: URL: https://github.com/apache/inlong/pull/6688#discussion_r1036009305 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java: ## @@ -149,6 +171,35 @@ public void de

[GitHub] [inlong] healchow commented on pull request #6684: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter

healchow commented on PR #6684: URL: https://github.com/apache/inlong/pull/6684#issuecomment-1332290577 We recommend not creating a new PR, because all of the comments of this PR will not appear in your newly PR. -- This is an automated message from the Apache Git Service. To respond to t

[GitHub] [inlong] wangpeix opened a new pull request, #6692: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter

wangpeix opened a new pull request, #6692: URL: https://github.com/apache/inlong/pull/6692 ### Prepare a Pull Request - Title: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the `metrics.audit.proxy.hosts` parameter - Fixes #6675 ### Motivation

[GitHub] [inlong] wangpeix commented on pull request #6684: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter

wangpeix commented on PR #6684: URL: https://github.com/apache/inlong/pull/6684#issuecomment-1332399305 Thanks for reminding, thanks @healchow -- 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

[GitHub] [inlong] wangpeix commented on pull request #6692: [INLONG-6675][Sort] Sort does not report metrics because Flink Sql missing the metrics.audit.proxy.hosts parameter

wangpeix commented on PR #6692: URL: https://github.com/apache/inlong/pull/6692#issuecomment-1332407548 I created a new pr. Please help me review the code, thank you. @gong -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [inlong] ZuoFengZhang opened a new pull request, #6693: [INLONG-6689][Docker] Support running docker-compose on Arm Chip

ZuoFengZhang opened a new pull request, #6693: URL: https://github.com/apache/inlong/pull/6693 ### Support running docker-compose on Arm Chip #6689 - Title Example: [INLONG-XYZ][Component] Title of the pull request ### Motivation Specify the `--platform` param

[GitHub] [inlong] healchow commented on a diff in pull request #6692: [INLONG-6675][Sort] Add metrics.audit.proxy.hosts option to support report metrics

healchow commented on code in PR #6692: URL: https://github.com/apache/inlong/pull/6692#discussion_r1036633101 ## inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java: ## @@ -58,6 +58,12 @@ public static void main(String[] args) throws Exception { Pa

[GitHub] [inlong] healchow commented on a diff in pull request #6658: [INLONG-6657][Sort] Add dirty data metric for Hive

healchow commented on code in PR #6658: URL: https://github.com/apache/inlong/pull/6658#discussion_r1036634090 ## inlong-sort/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/AbstractStreamingWriter.java: ## @@ -195,14 +199,20 @@ public void processWater

[GitHub] [inlong] yunqingmoswu merged pull request #6670: [INLONG-6584][Sort] Add read phase metric and table level metric for MySQL

yunqingmoswu merged PR #6670: URL: https://github.com/apache/inlong/pull/6670 -- 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 (0671c3a45 -> 40e888598)

This is an automated email from the ASF dual-hosted git repository. yunqing pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 0671c3a45 [INLONG-6678][Dashboard] Add sinkType parameter in sinkFieldList (#6679) add 40e888598 [INLONG-6584][

[GitHub] [inlong] wangpeix commented on a diff in pull request #6692: [INLONG-6675][Sort] Add metrics.audit.proxy.hosts option to support report metrics

wangpeix commented on code in PR #6692: URL: https://github.com/apache/inlong/pull/6692#discussion_r1036642524 ## inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java: ## @@ -58,6 +58,12 @@ public static void main(String[] args) throws Exception { Pa

[GitHub] [inlong] gong commented on a diff in pull request #6692: [INLONG-6675][Sort] Add metrics.audit.proxy.hosts option to support report metrics

gong commented on code in PR #6692: URL: https://github.com/apache/inlong/pull/6692#discussion_r1036647858 ## inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java: ## @@ -58,6 +58,12 @@ public static void main(String[] args) throws Exception { Parser

[GitHub] [inlong] gong commented on a diff in pull request #6692: [INLONG-6675][Sort] Add metrics.audit.proxy.hosts option to support report metrics

gong commented on code in PR #6692: URL: https://github.com/apache/inlong/pull/6692#discussion_r1036647858 ## inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java: ## @@ -58,6 +58,12 @@ public static void main(String[] args) throws Exception { Parser

[GitHub] [inlong] gosonzhang opened a new pull request, #6695: [INLONG-6638][TubeMQ] C++ client supports filtering consume with the "-" character (addendum)

gosonzhang opened a new pull request, #6695: URL: https://github.com/apache/inlong/pull/6695 - Fixes #6638 Supplementary repair, adjust the verification rules -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [inlong] leezng opened a new pull request, #6696: [INLONG-6694][Dashboard] Create with filter value first, if there is a filter plugin

leezng opened a new pull request, #6696: URL: https://github.com/apache/inlong/pull/6696 - Fixes #6694 -- 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-mai

[GitHub] [inlong] dockerzhang commented on pull request #6693: [INLONG-6689][Docker] Support running docker-compose on Arm Chip

dockerzhang commented on PR #6693: URL: https://github.com/apache/inlong/pull/6693#issuecomment-1333169720 ``` ERROR: The Compose file './docker-compose.yml' is invalid because: Unsupported config option for services.mysql: 'platform' ``` -- This is an automated message from the A

[GitHub] [inlong] EMsnap commented on a diff in pull request #6688: [INLONG-6671][Sort] Supports dirty data side-output for kafka connector

EMsnap commented on code in PR #6688: URL: https://github.com/apache/inlong/pull/6688#discussion_r1036740045 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java: ## @@ -149,6 +171,35 @@ public void deserial

[GitHub] [inlong] yunqingmoswu merged pull request #6688: [INLONG-6671][Sort] Supports dirty data side-output for kafka connector

yunqingmoswu merged PR #6688: URL: https://github.com/apache/inlong/pull/6688 -- 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-6671][Sort] Supports dirty data side-output for kafka connector (#6688)

This is an automated email from the ASF dual-hosted git repository. yunqing 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 09bae48fe [INLONG-6671][Sort] Supports dirty da

[GitHub] [inlong] gosonzhang merged pull request #6695: [INLONG-6638][TubeMQ] C++ client supports filtering consume with the "-" character (addendum)

gosonzhang merged PR #6695: URL: https://github.com/apache/inlong/pull/6695 -- 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 master updated (09bae48fe -> 53e81113a)

This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 09bae48fe [INLONG-6671][Sort] Supports dirty data side-output for kafka connector (#6688) add 53e81113a [INL

[GitHub] [inlong] leezng merged pull request #6696: [INLONG-6694][Dashboard] Create with filter value first, if there is a filter plugin

leezng merged PR #6696: URL: https://github.com/apache/inlong/pull/6696 -- 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: [INLONG-6694][Dashboard] Create with filter value first, if there is a filter plugin (#6696)

This is an automated email from the ASF dual-hosted git repository. leezng 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 3ad3e463d [INLONG-6694][Dashboard] Create with f

[GitHub] [inlong] bluewang opened a new pull request, #6698: [INLONG-6697][Dashboard] Optimize iceberg sink Required

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

[GitHub] [inlong] dockerzhang commented on a diff in pull request #6692: [INLONG-6675][Sort] Add metrics.audit.proxy.hosts option to support report metrics

dockerzhang commented on code in PR #6692: URL: https://github.com/apache/inlong/pull/6692#discussion_r1036777413 ## inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java: ## @@ -285,6 +285,8 @@ private String[] genProgramArgsV2(Fl