[PR] [INLONG-9944][Dashboard] Add Agent and Installer for Agent Cluster Node [inlong]

2024-04-08 Thread via GitHub
haifxu opened a new pull request, #9945: URL: https://github.com/apache/inlong/pull/9945 ### Prepare a Pull Request - Fixes #9944 ### Motivation Add `Agent` and `Installer` for Agent Cluster Node. ### Modifications 1. Get node info and only keep the first e

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556760249 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/source/JdbcSource.java: ## @@ -0,0 +1,306 @@ +/* + * Licensed to the Apache Software Foundation (A

(inlong) branch master updated: [INLONG-9920][Audit] Audit-service add codes of source (#9941)

2024-04-08 Thread gosonzhang
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 da4c77e2cd [INLONG-9920][Audit] Audit-servic

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
gosonzhang merged PR #9941: URL: https://github.com/apache/inlong/pull/9941 -- 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

[PR] [INLONG-9921][Manager] Fix the problem of manager can't stop data sync job [inlong]

2024-04-08 Thread via GitHub
fuweng11 opened a new pull request, #9942: URL: https://github.com/apache/inlong/pull/9942 ### Prepare a Pull Request - Fixes #9921 ### Motivation Fix the problem of manager can't stop data sync job. ### Modifications Fix the problem of manager can't

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556760986 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/source/JdbcSource.java: ## @@ -0,0 +1,306 @@ +/* + * Licensed to the Apache Software Foundation (A

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556760249 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/source/JdbcSource.java: ## @@ -0,0 +1,306 @@ +/* + * Licensed to the Apache Software Foundation (A

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556750852 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/selector/impl/DBDataSource.java: ## @@ -29,28 +32,17 @@ import java.text.MessageFormat; import j

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556747686 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/source/JdbcSource.java: ## @@ -0,0 +1,306 @@ +/* + * Licensed to the Apache Software Foundation (A

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
doleyzi commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556746411 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/selector/impl/DBDataSource.java: ## @@ -29,28 +32,17 @@ import java.text.MessageFormat; import java

Re: [PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9941: URL: https://github.com/apache/inlong/pull/9941#discussion_r1556738406 ## inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/selector/impl/DBDataSource.java: ## @@ -29,28 +32,17 @@ import java.text.MessageFormat; import j

[PR] [INLONG-9920][Audit] Audit-service add codes of source [inlong]

2024-04-08 Thread via GitHub
doleyzi opened a new pull request, #9941: URL: https://github.com/apache/inlong/pull/9941 ### Prepare a Pull Request - Fixes #9920 ### Motivation *Add codes of source in audit-service module to real-time statistics of data from clickhouse, mysql and other data sources*

(inlong) branch master updated: [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters (#9937)

2024-04-08 Thread dockerzhang
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 84bd8b247d [INLONG-9936][Manager] Support f

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
dockerzhang merged PR #9937: URL: https://github.com/apache/inlong/pull/9937 -- 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-9932][Manager] Add an agent installer module management for agent installation (#9933)

2024-04-08 Thread dockerzhang
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 f2263cea7a [INLONG-9932][Manager] Add an ag

Re: [PR] [INLONG-9932][Manager] Add an agent installer module management for agent installation [inlong]

2024-04-08 Thread via GitHub
dockerzhang merged PR #9933: URL: https://github.com/apache/inlong/pull/9933 -- 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.

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
luchunliang commented on code in PR #9937: URL: https://github.com/apache/inlong/pull/9937#discussion_r186684 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarQueueResourceOperator.java: ## @@ -303,35 +309,34 @@ pr

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
fuweng11 commented on code in PR #9937: URL: https://github.com/apache/inlong/pull/9937#discussion_r173650 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarQueueResourceOperator.java: ## @@ -303,35 +309,34 @@ priva

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
luchunliang commented on code in PR #9937: URL: https://github.com/apache/inlong/pull/9937#discussion_r118367 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/QueryLatestMessagesRunnable.java: ## @@ -0,0 +1,83 @@ +/* + *

(inlong) branch master updated: [INLONG-9938][Dashboard] Support Agent module and package page (#9939)

2024-04-08 Thread dockerzhang
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 e3543ccea8 [INLONG-9938][Dashboard] Support

Re: [PR] [INLONG-9938][Dashboard] Support Agent module and package page [inlong]

2024-04-08 Thread via GitHub
dockerzhang merged PR #9939: URL: https://github.com/apache/inlong/pull/9939 -- 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.

Re: [PR] [INLONG-9932][Manager] Add an agent installer module management for agent installation [inlong]

2024-04-08 Thread via GitHub
fuweng11 commented on code in PR #9933: URL: https://github.com/apache/inlong/pull/9933#discussion_r1555485764 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java: ## @@ -42,16 +51,48 @@ @ApiModel("Agent cluster nod

Re: [I] [Improve][Sort] Errors in UT test logs for sort-end-to-end-tests, but UT results show as successful [inlong]

2024-04-08 Thread via GitHub
XiaoYou201 commented on issue #9402: URL: https://github.com/apache/inlong/issues/9402#issuecomment-2042239416 Case1 causes a warning due to a problem with the Java version, In #9940 , change the flink java version to 1.8. Case2 causes a error due to a other module influent network adapte

[PR] [INLONG-9402][Sort] Solve errors in UT test logs for sort-end-to-end-tests, but UT results show as successful [inlong]

2024-04-08 Thread via GitHub
XiaoYou201 opened a new pull request, #9940: URL: https://github.com/apache/inlong/pull/9940 ### Prepare a Pull Request - [INLONG-9402][Sort] Solve errors in UT test logs for sort-end-to-end-tests, but UT results show as successful - Fixes #9402 ### Motivation As

[PR] [INLONG-9938][Dashboard] Support Agent module and package page [inlong]

2024-04-08 Thread via GitHub
haifxu opened a new pull request, #9939: URL: https://github.com/apache/inlong/pull/9939 ### Prepare a Pull Request - Fixes #9938 ### Motivation Add Agent module and package page. ### Modifications 1. Update menus and routes; 2. The tag page and modal pa

Re: [PR] [INLONG-9932][Manager] Add an agent installer module management for agent installation [inlong]

2024-04-08 Thread via GitHub
vernedeng commented on code in PR #9933: URL: https://github.com/apache/inlong/pull/9933#discussion_r1555440768 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java: ## @@ -42,16 +51,48 @@ @ApiModel("Agent cluster no

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9937: URL: https://github.com/apache/inlong/pull/9937#discussion_r1555374915 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/QueryLatestMessagesRunnable.java: ## @@ -0,0 +1,83 @@ +/* + *

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
aloyszhang commented on code in PR #9937: URL: https://github.com/apache/inlong/pull/9937#discussion_r1555374915 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/QueryLatestMessagesRunnable.java: ## @@ -0,0 +1,83 @@ +/* + *

Re: [PR] [INLONG-9936][Manager] Support for parallel acquisition of data preview data from multiple Pulsar clusters [inlong]

2024-04-08 Thread via GitHub
luchunliang commented on PR #9937: URL: https://github.com/apache/inlong/pull/9937#issuecomment-2042024772 > The messages from all clusters are mixed, is it ok? It is ok, the messages come from a InLong stream of a cluster tag, they have same protocol. -- This is an automated messa