[GitHub] [inlong] dockerzhang merged pull request #7939: [INLONG-7938][Manager] Fix consume list interface does not filter by request

dockerzhang merged PR #7939: URL: https://github.com/apache/inlong/pull/7939 -- 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-7938][Manager] Fix consume list interface does not filter by request (#7939)

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 4eea8d3d9 [INLONG-7938][Manager] Fix consum

[GitHub] [inlong] xuehuanran commented on a diff in pull request #7933: [INLONG-7926][TubeMQ] Add "Register2Master" method for GO SDK

xuehuanran commented on code in PR #7933: URL: https://github.com/apache/inlong/pull/7933#discussion_r1185058338 ## inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/producer_impl.go: ## @@ -0,0 +1,200 @@ +// Licensed to the Apache Software Foundation (ASF) under one +//

[GitHub] [inlong] xuehuanran commented on a diff in pull request #7933: [INLONG-7926][TubeMQ] Add "Register2Master" method for GO SDK

xuehuanran commented on code in PR #7933: URL: https://github.com/apache/inlong/pull/7933#discussion_r1185062731 ## inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/producer.go: ## @@ -0,0 +1,21 @@ +// Licensed to the Apache Software Foundation (ASF) under one +// or mo

[GitHub] [inlong] TszKitLo40 commented on a diff in pull request #7933: [INLONG-7926][TubeMQ] Add "Register2Master" method for GO SDK

TszKitLo40 commented on code in PR #7933: URL: https://github.com/apache/inlong/pull/7933#discussion_r1185617475 ## inlong-tubemq/tubemq-client-twins/tubemq-client-go/util/util.go: ## @@ -147,3 +150,17 @@ func Join(m map[string]string, step1 string, step2 string) string {

[GitHub] [inlong] bluewang opened a new pull request, #7956: [INLONG-7955][Dashboard] Change the consumption query method from get to post

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

[GitHub] [inlong] EMsnap merged pull request #7951: [INLONG-7945][Sort] Fix MongoDB CDC unable to output the 'replace' records

EMsnap merged PR #7951: URL: https://github.com/apache/inlong/pull/7951 -- 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 (4eea8d3d9 -> 0d80d4de5)

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 4eea8d3d9 [INLONG-7938][Manager] Fix consume list interface does not filter by request (#7939) add 0d80d4de5 [INL

[GitHub] [inlong] EMsnap merged pull request #7953: [INLONG-7952][Sort] Mask sensitive message of Flink SQL in the logs

EMsnap merged PR #7953: URL: https://github.com/apache/inlong/pull/7953 -- 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 (0d80d4de5 -> 3f4ebb520)

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 0d80d4de5 [INLONG-7945][Sort] Fix MongoDB CDC unable to output the 'replace' records (#7951) add 3f4ebb520 [INLON

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! The rawdatahashpa

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! The rawdatahashpa

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! The rawdatahashpa

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! The rawdatahashpa

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! The rawdatahashpa

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! The rawdatahashpa

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! Purpose-wise the

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! RawdataHashParti

[GitHub] [inlong] Yizhou-Yang commented on a diff in pull request #7924: [INLONG-7900][Sort] Support partition by primary key when upsert single table of Kafka

Yizhou-Yang commented on code in PR #7924: URL: https://github.com/apache/inlong/pull/7924#discussion_r1185687301 ## inlong-sort/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/partitioner/PrimaryKeyPartitioner.java: ## Review Comment: Hi! RawdataHashParti