[inlong] branch branch-1.5 updated (c7af0fcc0 -> 3db90d470)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git from c7af0fcc0 [INLONG-7138][Manager] Support the connection test for kafka, tube, starrocks, etc (#7142) ne

[inlong] 03/07: [INLONG-7103][Sort] Support InLongMsg format in Kafka (#7107)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit d2fe1614c4ba7ca14ddd4a2edebd60c940802c95 Author: feat AuthorDate: Thu Jan 5 10:35:58 2023 +0800 [INLONG-71

[inlong] 02/07: [INLONG-7151][Manager] Fix failure to create node when init sort (#7152)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 871027aa47d7ccde99a326266da81b73d310bef0 Author: haifxu AuthorDate: Thu Jan 5 09:49:52 2023 +0800 [INLONG-

[inlong] 04/07: [INLONG-7144][Manager] Add interface field limit (#7147)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 903183c6efa578698aca5441b41c79816aaaba0d Author: Goson Zhang <4675...@qq.com> AuthorDate: Thu Jan 5 11:03:59 202

[inlong] 01/07: [INLONG-7149][Manager] Replace tableName in ClickHouseLoadNode with databaseName.tableName (#7150)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit a4f707b60d1bfcf1410cb74e2da0bbcdc4a9ded0 Author: fuweng11 <76141879+fuwen...@users.noreply.github.com> AuthorDat

[inlong] 07/07: [INLONG-7154][SDK] Fix metric report failure when topic does not exist (#7158)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 3db90d470d53118d8c8b9f7acd3c479b54f63a27 Author: vernedeng AuthorDate: Thu Jan 5 14:58:31 2023 +0800 [INLO

[inlong] 05/07: [INLONG-7139][Dashboard] Cluster and node support for connectivity testing (#7145)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 9e678266313b3025bfd5416b6adb413a4754a548 Author: Lizhen <88174078+bluew...@users.noreply.github.com> AuthorDate:

[inlong] 06/07: [INLONG-7153][Dashboard] The data subscription status code shows the specific meaning (#7155)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit d4b128d63304b5e85263ff07833f2cf1473c537f Author: Lizhen <88174078+bluew...@users.noreply.github.com> AuthorDate:

[GitHub] [inlong] doleyzi opened a new pull request, #7160: [INLONG-7159][Audit] Fix the problem of audit sdk create thread

doleyzi opened a new pull request, #7160: URL: https://github.com/apache/inlong/pull/7160 …not deployed ### Prepare a Pull Request *(Change the title refer to the following example)* - [INLONG-7159][Audit] Fix the problem of audit sdk create thread when the audit service is

[GitHub] [inlong] dockerzhang merged pull request #7157: [INLONG-7156][Agent] Support directly sending raw file data

dockerzhang merged PR #7157: URL: https://github.com/apache/inlong/pull/7157 -- 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 (a5bacfa1d -> a5425ace1)

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 a5bacfa1d [INLONG-7154][SDK] Fix metric report failure when topic does not exist (#7158) add a5425ace1 [INL

[GitHub] [inlong] EMsnap opened a new pull request, #7164: [INLONG-7161][Sort] Fix bug that Mysql connector only output the latest record in snapshot stage for table without primary key

EMsnap opened a new pull request, #7164: URL: https://github.com/apache/inlong/pull/7164 ### Prepare a Pull Request - Fixes #7161 ### Motivation Mysql connector only output the latest record in snapshot stage for table without primary key ### Modifications when normal

[GitHub] [inlong] gosonzhang commented on a diff in pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

gosonzhang commented on code in PR #7134: URL: https://github.com/apache/inlong/pull/7134#discussion_r1062252527 ## inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql: ## @@ -330,7 +330,7 @@ CREATE TABLE IF NOT EXISTS `stream_source` `uuid`

[inlong] branch master updated: [INLONG-7159][Audit] Fix the problem of audit sdk create thread not deployed (#7160)

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 5dec75571 [INLONG-7159][Audit] Fix the prob

[GitHub] [inlong] dockerzhang merged pull request #7160: [INLONG-7159][Audit] Fix the problem of audit sdk create thread not deployed

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

[GitHub] [inlong] bluewang opened a new pull request, #7165: [INLONG-7162][Dashboard] Kafka MQ type details optimization

bluewang opened a new pull request, #7165: URL: https://github.com/apache/inlong/pull/7165 ### 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] woofyzhao opened a new pull request, #7167: [INLONG-7166][DataProxy] Fix audit data reporting

woofyzhao opened a new pull request, #7167: URL: https://github.com/apache/inlong/pull/7167 - Fixes #7166 ### Modifications - add audit report for new mq sink - fix concurrency issue on config operation -- This is an automated message from the Apache Git Service. T

[GitHub] [inlong] luchunliang commented on a diff in pull request #7167: [INLONG-7166][DataProxy] Fix audit data reporting

luchunliang commented on code in PR #7167: URL: https://github.com/apache/inlong/pull/7167#discussion_r1062309646 ## inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/kafka/KafkaHandler.java: ## @@ -238,6 +243,7 @@ public void onCompletion(Recor

[GitHub] [inlong] dockerzhang merged pull request #7134: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group

dockerzhang merged PR #7134: URL: https://github.com/apache/inlong/pull/7134 -- 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-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group (#7134)

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 bfc7e3b3a [INLONG-7089][Manager] Separate t

[GitHub] [inlong] leezng merged pull request #7165: [INLONG-7162][Dashboard] Kafka MQ type details optimization

leezng merged PR #7165: URL: https://github.com/apache/inlong/pull/7165 -- 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-7162][Dashboard] Kafka MQ type details optimization (#7165)

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 ef3dc848b [INLONG-7162][Dashboard] Kafka MQ type

[GitHub] [inlong] dockerzhang merged pull request #7164: [INLONG-7161][Sort] Fix bug that Mysql connector only output the latest record in snapshot stage for table without primary key

dockerzhang merged PR #7164: URL: https://github.com/apache/inlong/pull/7164 -- 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-7161][Sort] Fix bug that Mysql connector only output the latest record in snapshot stage for table without primary key (#7164)

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 f8d4eac64 [INLONG-7161][Sort] Fix bug that

[GitHub] [inlong] gosonzhang opened a new pull request, #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

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

[inlong] 04/05: [INLONG-7162][Dashboard] Kafka MQ type details optimization (#7165)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 34f7f04cb1e64aebf85a8d90574e741dab0aa629 Author: Lizhen <88174078+bluew...@users.noreply.github.com> AuthorDate:

[inlong] 02/05: [INLONG-7159][Audit] Fix the problem of audit sdk create thread not deployed (#7160)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit fddfceacb5119c1709aa3eb9757298fc07d312a5 Author: doleyzi <43397300+dole...@users.noreply.github.com> AuthorDate:

[inlong] 01/05: [INLONG-7156][Agent] Support directly sending raw file data (#7157)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit e26610ff1de43db5ecbe1eb548724630e9d3ee7e Author: xueyingzhang <86780714+poc...@users.noreply.github.com> AuthorD

[inlong] branch branch-1.5 updated (3db90d470 -> b96d4ed4a)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git from 3db90d470 [INLONG-7154][SDK] Fix metric report failure when topic does not exist (#7158) new e26610ff1

[inlong] 05/05: [INLONG-7161][Sort] Fix bug that Mysql connector only output the latest record in snapshot stage for table without primary key (#7164)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit b96d4ed4aa21f917ae2c49833e3a2925c295c3f5 Author: Schnapps AuthorDate: Thu Jan 5 19:19:02 2023 +0800 [INLON

[inlong] 03/05: [INLONG-7089][Manager] Separate the concept of node tag from the node table and extract the concept of task group (#7134)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git commit db296b39df069afca8ac6d8755ffc67395e2262a Author: thesumery <107393625+thesum...@users.noreply.github.com> Author

[GitHub] [inlong] woofyzhao merged pull request #7167: [INLONG-7166][DataProxy] Fix audit data reporting

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

[inlong] branch master updated: [INLONG-7166][DataProxy] Fix audit data reporting (#7167)

This is an automated email from the ASF dual-hosted git repository. woofyzhao 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 8db88eccc [INLONG-7166][DataProxy] Fix audit

[GitHub] [inlong] healchow opened a new pull request, #7171: [INLONG-5776][Manager] Add tenant param to InlongGroup that uses Pulsar

healchow opened a new pull request, #7171: URL: https://github.com/apache/inlong/pull/7171 ### Prepare a Pull Request - Fixes #5776 ### Motivation **Add tenant param to InlongGroup that uses Pulsar.** Currently, the tenant parameter is stored in the Pulsar cluster

[inlong] branch branch-1.5 updated: [INLONG-7166][DataProxy] Fix audit data reporting (#7167)

This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.5 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/branch-1.5 by this push: new 43b821ac4 [INLONG-7166][DataProxy]

[GitHub] [inlong] healchow commented on a diff in pull request #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

healchow commented on code in PR #7170: URL: https://github.com/apache/inlong/pull/7170#discussion_r1063051079 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchDataNodeDTO.java: ## @@ -85,8 +85,8 @@ public static ElasticsearchDataN

[GitHub] [inlong] healchow commented on a diff in pull request #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

healchow commented on code in PR #7170: URL: https://github.com/apache/inlong/pull/7170#discussion_r1063052302 ## inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenDataNodeController.java: ## @@ -71,24 +70,21 @@ public Response> list(@

[GitHub] [inlong] gosonzhang commented on a diff in pull request #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

gosonzhang commented on code in PR #7170: URL: https://github.com/apache/inlong/pull/7170#discussion_r1063055036 ## inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenDataNodeController.java: ## @@ -71,24 +70,21 @@ public Response> list

[GitHub] [inlong] gosonzhang commented on a diff in pull request #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

gosonzhang commented on code in PR #7170: URL: https://github.com/apache/inlong/pull/7170#discussion_r1063055732 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchDataNodeDTO.java: ## @@ -85,8 +85,8 @@ public static ElasticsearchDat

[GitHub] [inlong] e-mhui opened a new pull request, #7173: [INLONG-7172][Sort] Fix newly table write into iceberg failed

e-mhui opened a new pull request, #7173: URL: https://github.com/apache/inlong/pull/7173 ### Prepare a Pull Request [INLONG-7172][Sort] Fix newly table write into iceberg failed - Fixes #7172 ### Motivation When a newly table is added in the Flink job, and then r

[GitHub] [inlong] EMsnap commented on a diff in pull request #7173: [INLONG-7172][Sort] Fix new table write into iceberg failed

EMsnap commented on code in PR #7173: URL: https://github.com/apache/inlong/pull/7173#discussion_r1063149606 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java: ## @@ -161,6 +161,10 @@ public void init

[GitHub] [inlong] e-mhui commented on a diff in pull request #7173: [INLONG-7172][Sort] Fix new table write into iceberg failed

e-mhui commented on code in PR #7173: URL: https://github.com/apache/inlong/pull/7173#discussion_r1063151341 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java: ## @@ -161,6 +161,10 @@ public void init

[GitHub] [inlong] healchow commented on a diff in pull request #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

healchow commented on code in PR #7170: URL: https://github.com/apache/inlong/pull/7170#discussion_r1063173081 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchDataNodeDTO.java: ## @@ -85,8 +85,8 @@ public static ElasticsearchDataN

[GitHub] [inlong] gosonzhang commented on a diff in pull request #7170: [INLONG-7169][Manager] Optimize OpenDataNodeController implementation

gosonzhang commented on code in PR #7170: URL: https://github.com/apache/inlong/pull/7170#discussion_r1063178361 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/es/ElasticsearchDataNodeDTO.java: ## @@ -85,8 +85,8 @@ public static ElasticsearchDat

[GitHub] [inlong] EMsnap commented on a diff in pull request #7173: [INLONG-7172][Sort] Fix new table write into iceberg failed

EMsnap commented on code in PR #7173: URL: https://github.com/apache/inlong/pull/7173#discussion_r1063184873 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java: ## @@ -160,7 +160,7 @@ public void initi

[GitHub] [inlong] e-mhui commented on a diff in pull request #7173: [INLONG-7172][Sort] Fix new table write into iceberg failed

e-mhui commented on code in PR #7173: URL: https://github.com/apache/inlong/pull/7173#discussion_r1063193835 ## inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java: ## @@ -160,7 +160,7 @@ public void initi

[GitHub] [inlong] EMsnap opened a new pull request, #7175: [INLONG-7161][Sort] Fix bug that Mysql connector only output the latest record in snapshot stage for table without primary key - 2

EMsnap opened a new pull request, #7175: URL: https://github.com/apache/inlong/pull/7175 ### Prepare a Pull Request - Fixes #7161 ### Motivation - Fixes #7161 ### Modifications This a supplement for 7161 ### Verifying this change ### Documentati