[GitHub] [inlong] gosonzhang merged pull request #6059: [INLONG-6058][DataProxy] Add parameter checking and optimize client creation logic

gosonzhang merged PR #6059: URL: https://github.com/apache/inlong/pull/6059 -- 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: [INLONG-6058][DataProxy] Add parameter checking and optimize client creation logic (#6059)

This is an automated email from the ASF dual-hosted git repository. gosonzhang 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 c1c3befc5 [INLONG-6058][DataProxy] Add param

[inlong] branch release-1.3.0 updated: [INLONG-6040][DataProxy] DataProxy does not fully update the configurations (#6041)

This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new a78b25523 [INLONG-6040][DataPr

[inlong] branch release-1.3.0 updated: [INLONG-6058][DataProxy] Add parameter checking and optimize client creation logic (#6059)

This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new f92f53513 [INLONG-6058][DataPr

[GitHub] [inlong] Keylchen closed pull request #6037: [INLONG-6037][Agent] Reconstruct AgentPrometheusListener to fix custom prometheus exporter error.

Keylchen closed pull request #6037: [INLONG-6037][Agent] Reconstruct AgentPrometheusListener to fix custom prometheus exporter error. URL: https://github.com/apache/inlong/pull/6037 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [inlong] healchow commented on a diff in pull request #6043: [INLONG-6042][Manager] Support delete DataNode by name

healchow commented on code in PR #6043: URL: https://github.com/apache/inlong/pull/6043#discussion_r983283632 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java: ## @@ -142,6 +142,20 @@ public Boolean delete(Integer id

[GitHub] [inlong] healchow commented on a diff in pull request #6043: [INLONG-6042][Manager] Support delete DataNode by name

healchow commented on code in PR #6043: URL: https://github.com/apache/inlong/pull/6043#discussion_r983284343 ## inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/DataNodeClient.java: ## @@ -107,4 +107,17 @@ public Boolean delete(Integ

[GitHub] [inlong] liaorui opened a new pull request, #6060: [INLONG-][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

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

[GitHub] [inlong] woofyzhao opened a new pull request, #6064: [INLONG-6063][Manager] Utilize ClickHouse and Iceberg data node

woofyzhao opened a new pull request, #6064: URL: https://github.com/apache/inlong/pull/6064 - Fixes #6063 -- 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 uns

[GitHub] [inlong] woofyzhao commented on a diff in pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

woofyzhao commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983365278 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tdsqlkafka/TdsqlKafkaSourceOperation.java: ## @@ -0,0 +1,81 @@ +/* + * Licensed

[GitHub] [inlong] healchow commented on a diff in pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

healchow commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983382200 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/format/ProtobufFormat.java: ## @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [inlong] healchow commented on a diff in pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

healchow commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983383998 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/TdsqlKafkaConstant.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] healchow commented on a diff in pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

healchow commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983384722 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tdsqlkafka/TdsqlKafkaSourceOperation.java: ## @@ -0,0 +1,81 @@ +/* + * Licensed

[GitHub] [inlong] healchow commented on a diff in pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

healchow commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983385023 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/tdsqlkafka/TdsqlKafkaSourceOperation.java: ## @@ -0,0 +1,81 @@ +/* + * Licensed

[GitHub] [inlong] healchow commented on a diff in pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

healchow commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983385805 ## inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java: ## @@ -31,8 +31,10 @@ public enum TaskTypeEnum { MONGODB(9), TUBEMQ(10),

[GitHub] [inlong] woofyzhao commented on a diff in pull request #6046: [INLONG-6044][Manager] Distinguish between group and stream configuration processes

woofyzhao commented on code in PR #6046: URL: https://github.com/apache/inlong/pull/6046#discussion_r983393423 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/group/InitGroupCompleteListener.java: ## @@ -84,12 +87,9 @@ public ListenerRe

[GitHub] [inlong] gosonzhang opened a new pull request, #6066: [INLONG-6065][DataProxy] Delete the Pulsar client synchronously when deleting a topic

gosonzhang opened a new pull request, #6066: URL: https://github.com/apache/inlong/pull/6066 - Fixes #6065 -- 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 unsubscri

[GitHub] [inlong] liaorui closed pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

liaorui closed pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL URL: https://github.com/apache/inlong/pull/6060 -- 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 t

[GitHub] [inlong] liaorui commented on pull request #6060: [INLONG-6061][Sort]Support to generate DTS TDSQL-Kafka Connector Flink SQL

liaorui commented on PR #6060: URL: https://github.com/apache/inlong/pull/6060#issuecomment-1262121765 manager and sort changes merged toghther. I will submit another PR with single sort changes. -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [inlong] liaorui opened a new pull request, #6067: Support generating DTS TDSQL-Kafka Connector Flink SQL

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

[GitHub] [inlong] EMsnap commented on a diff in pull request #6067: [INLONG-6061][Sort]Support generating DTS TDSQL-Kafka Connector Flink SQL

EMsnap commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r983408952 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/format/ProtobufFormat.java: ## @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache Software Found

[GitHub] [inlong] healchow commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

healchow commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r983412228 ## inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java: ## @@ -31,8 +31,10 @@ public enum TaskTypeEnum { MONGODB(9), TUBEMQ(10),

[GitHub] [inlong] healchow commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

healchow commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r983413086 ## inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java: ## @@ -31,8 +31,10 @@ public enum TaskTypeEnum { MONGODB(9), TUBEMQ(10),

[GitHub] [inlong] healchow commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

healchow commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r983413982 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/format/ProtobufFormat.java: ## @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache Software Fou

[GitHub] [inlong] healchow commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

healchow commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r983414863 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/TdsqlKafkaConstant.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] healchow commented on a diff in pull request #6060: [INLONG-6061][Sort] Support TDSQL-Kafka connector

healchow commented on code in PR #6060: URL: https://github.com/apache/inlong/pull/6060#discussion_r983383998 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/TdsqlKafkaConstant.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] healchow commented on a diff in pull request #6064: [INLONG-6063][Manager] Utilize ClickHouse and Iceberg data node

healchow commented on code in PR #6064: URL: https://github.com/apache/inlong/pull/6064#discussion_r983419010 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperator.java: ## @@ -83,6 +87,15 @@ public StreamSink getFromE

[GitHub] [inlong] healchow commented on a diff in pull request #6064: [INLONG-6063][Manager] Utilize ClickHouse and Iceberg data node

healchow commented on code in PR #6064: URL: https://github.com/apache/inlong/pull/6064#discussion_r983420274 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/iceberg/IcebergResourceOperator.java: ## @@ -78,11 +87,27 @@ public void

[GitHub] [inlong] vernedeng commented on a diff in pull request #6043: [INLONG-6042][Manager] Support delete DataNode by name

vernedeng commented on code in PR #6043: URL: https://github.com/apache/inlong/pull/6043#discussion_r983424962 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java: ## @@ -142,6 +142,20 @@ public Boolean delete(Integer i

[GitHub] [inlong] gosonzhang opened a new pull request, #6070: [INLONG-6069][Audit] Not initialized before clickhouse starts

gosonzhang opened a new pull request, #6070: URL: https://github.com/apache/inlong/pull/6070 - Fixes #6069 -- 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 unsubs

[GitHub] [inlong] gosonzhang merged pull request #6066: [INLONG-6065][DataProxy] Delete the Pulsar client synchronously when deleting a topic

gosonzhang merged PR #6066: URL: https://github.com/apache/inlong/pull/6066 -- 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 (c1c3befc5 -> e4763d6ab)

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 c1c3befc5 [INLONG-6058][DataProxy] Add parameter checking and optimize client creation logic (#6059) add e47

[inlong] branch release-1.3.0 updated: [INLONG-6065][DataProxy] Delete the Pulsar client synchronously when deleting a topic (#6066)

This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new 9e7943edb [INLONG-6065][DataPr

[GitHub] [inlong] Yizhou-Yang opened a new pull request, #6072: [INLONG-6071][Manager] Add doris sink for manager

Yizhou-Yang opened a new pull request, #6072: URL: https://github.com/apache/inlong/pull/6072 initial doris sink, need connector implementation for further detail -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[inlong] branch master updated: [INLONG-6069][Audit] Initializing the ClickHouse service before its starts (#6070)

This is an automated email from the ASF dual-hosted git repository. gosonzhang 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 12f61c6a1 [INLONG-6069][Audit] Initializing

[GitHub] [inlong] gosonzhang merged pull request #6070: [INLONG-6069][Audit] Initializing the ClickHouse service before its starts

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

[GitHub] [inlong] Yizhou-Yang commented on pull request #6072: [INLONG-6071][Manager] Add doris sink for manager

Yizhou-Yang commented on PR #6072: URL: https://github.com/apache/inlong/pull/6072#issuecomment-1263057229 - [ ] -- 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 unsubsc

[GitHub] [inlong] Yizhou-Yang closed pull request #6072: [INLONG-6071][Manager] Add doris sink for manager

Yizhou-Yang closed pull request #6072: [INLONG-6071][Manager] Add doris sink for manager URL: https://github.com/apache/inlong/pull/6072 -- 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

[inlong] branch release-1.3.0 updated: [INLONG-6069][Audit] Initializing the ClickHouse service before its starts (#6070)

This is an automated email from the ASF dual-hosted git repository. gosonzhang pushed a commit to branch release-1.3.0 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/release-1.3.0 by this push: new 8182772f1 [INLONG-6069][Audit]

[GitHub] [inlong] lucaspeng12138 opened a new pull request, #6074: [INLONG-6073][Kubernetes] Add audit.config.store.mode Configurable to k8s

lucaspeng12138 opened a new pull request, #6074: URL: https://github.com/apache/inlong/pull/6074 ### Prepare a Pull Request Add audit.config.store.mode Configurable to k8s - Fixes #6073 ### Motivation Add audit.config.store.mode Configurable to k8s ### Modifica

[GitHub] [inlong] liaorui commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

liaorui commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r984183350 ## inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java: ## @@ -31,8 +31,10 @@ public enum TaskTypeEnum { MONGODB(9), TUBEMQ(10), R

[GitHub] [inlong] yunqingmoswu commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

yunqingmoswu commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r984188343 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/TdsqlKafkaConstant.java: ## @@ -0,0 +1,41 @@ +/* + * Licensed to the Apache Softw

[GitHub] [inlong] gong commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

gong commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r984189516 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/TdsqlKafkaExtractNode.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] gong commented on a diff in pull request #6067: [INLONG-6061][Sort] Support TDSQL-Kafka connector

gong commented on code in PR #6067: URL: https://github.com/apache/inlong/pull/6067#discussion_r984190461 ## inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/TdsqlKafkaExtractNode.java: ## @@ -0,0 +1,96 @@ +/* + * Licensed to the Apache Software

[GitHub] [inlong] Yizhou-Yang opened a new pull request, #6075: [Feature][Manager] Support Apache Doris sink

Yizhou-Yang opened a new pull request, #6075: URL: https://github.com/apache/inlong/pull/6075 #initial Doris sink, need connector implementation for further detail. Fixes: https://github.com/apache/inlong/issues/6071 -- This is an automated message from the Apache Git Service. To re

[GitHub] [inlong] gong commented on pull request #6064: [INLONG-6063][Manager] Utilize ClickHouse and Iceberg data node

gong commented on PR #6064: URL: https://github.com/apache/inlong/pull/6064#issuecomment-1263087389 I suggest add description about modifying hive -- 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