[GitHub] [inlong] healchow commented on a diff in pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
healchow commented on code in PR #7989: URL: https://github.com/apache/inlong/pull/7989#discussion_r1193430547 ## inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml: ## @@ -498,6 +523,38 @@ + +update strea

[GitHub] [inlong] healchow commented on a diff in pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
healchow commented on code in PR #7989: URL: https://github.com/apache/inlong/pull/7989#discussion_r1193443175 ## inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml: ## @@ -342,6 +342,29 @@ + Review Comment: C

[GitHub] [inlong] healchow commented on a diff in pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
healchow commented on code in PR #7989: URL: https://github.com/apache/inlong/pull/7989#discussion_r1193447058 ## inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml: ## @@ -498,6 +523,38 @@ + Review Comment: M

[GitHub] [inlong] dockerzhang merged pull request #8025: [INLONG-8024][Manager] Add extended properties when getting the status of the sort task info

2023-05-15 Thread via GitHub
dockerzhang merged PR #8025: URL: https://github.com/apache/inlong/pull/8025 -- 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-8024][Manager] Add extended properties when getting the status of the sort task info (#8025)

2023-05-15 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 32c416a78 [INLONG-8024][Manager] Add extend

[GitHub] [inlong] fuweng11 commented on a diff in pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
fuweng11 commented on code in PR #7989: URL: https://github.com/apache/inlong/pull/7989#discussion_r1193494901 ## inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml: ## @@ -498,6 +523,38 @@ + Review Comment: d

[GitHub] [inlong] fuweng11 commented on a diff in pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
fuweng11 commented on code in PR #7989: URL: https://github.com/apache/inlong/pull/7989#discussion_r1193495180 ## inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml: ## @@ -498,6 +523,38 @@ + +update strea

[GitHub] [inlong] healchow commented on a diff in pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
healchow commented on code in PR #7989: URL: https://github.com/apache/inlong/pull/7989#discussion_r1193565536 ## inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/StreamSourceEntityMapper.java: ## @@ -164,6 +171,21 @@ int updateIpAndUuid(@Param("id")

[GitHub] [inlong] dockerzhang merged pull request #7989: [INLONG-7987][Manager] Add heartbeat timeout status to the source

2023-05-15 Thread via GitHub
dockerzhang merged PR #7989: URL: https://github.com/apache/inlong/pull/7989 -- 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-7987][Manager] Add heartbeat timeout status to the source (#7989)

2023-05-15 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 d66775d01 [INLONG-7987][Manager] Add heartb

[GitHub] [inlong] aloyszhang merged pull request #8027: [INLONG-8026][Agent] Improve the Agent performance

2023-05-15 Thread via GitHub
aloyszhang merged PR #8027: URL: https://github.com/apache/inlong/pull/8027 -- 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-8026][Agent] Improve the Agent performance (#8027)

2023-05-15 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang 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 76a621696 [INLONG-8026][Agent] Improve the A

[GitHub] [inlong] fuweng11 opened a new pull request, #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
fuweng11 opened a new pull request, #8028: URL: https://github.com/apache/inlong/pull/8028 ### Prepare a Pull Request - Fixes #8021 ### Motivation Periodically delete sources with inconsistent states. ### Modifications Periodically delete sources with i

[inlong] branch branch-1.7 updated (412e56054 -> 4b99eac73)

2023-05-15 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a change to branch branch-1.7 in repository https://gitbox.apache.org/repos/asf/inlong.git from 412e56054 [INLONG-7971][Dashboard] Support batch import stream fields by Excel (#7972) new 91138d786 [I

[inlong] 03/03: [INLONG-8026][Agent] Improve the Agent performance (#8027)

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

[inlong] 01/03: [INLONG-8024][Manager] Add extended properties when getting the status of the sort task info (#8025)

2023-05-15 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.7 in repository https://gitbox.apache.org/repos/asf/inlong.git commit 91138d786813df53f779bf1d0baada6a0d61fa63 Author: chestnufang <65438734+chestnu...@users.noreply.github.com> Auth

[inlong] 02/03: [INLONG-7987][Manager] Add heartbeat timeout status to the source (#7989)

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

[GitHub] [inlong] vernedeng commented on a diff in pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
vernedeng commented on code in PR #8028: URL: https://github.com/apache/inlong/pull/8028#discussion_r1194009350 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java: ## @@ -663,4 +670,22 @@ public void run() {

[GitHub] [inlong] fuweng11 commented on a diff in pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
fuweng11 commented on code in PR #8028: URL: https://github.com/apache/inlong/pull/8028#discussion_r1194512285 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java: ## @@ -663,4 +670,22 @@ public void run() {

[GitHub] [inlong] github-actions[bot] commented on issue #6788: [Feature][Sort] Support the metric of Apache Hudi

2023-05-15 Thread via GitHub
github-actions[bot] commented on issue #6788: URL: https://github.com/apache/inlong/issues/6788#issuecomment-1548853257 This issue is stale because it has been open for 60 days with no activity. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [inlong] healchow commented on a diff in pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
healchow commented on code in PR #8028: URL: https://github.com/apache/inlong/pull/8028#discussion_r1194532005 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java: ## @@ -138,11 +144,30 @@ public class AgentServiceImp

[GitHub] [inlong] healchow commented on a diff in pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
healchow commented on code in PR #8028: URL: https://github.com/apache/inlong/pull/8028#discussion_r1194532005 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java: ## @@ -138,11 +144,30 @@ public class AgentServiceImp

[GitHub] [inlong] healchow commented on a diff in pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
healchow commented on code in PR #8028: URL: https://github.com/apache/inlong/pull/8028#discussion_r1194533835 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java: ## @@ -138,11 +144,30 @@ public class AgentServiceImp

[GitHub] [inlong] fuweng11 commented on a diff in pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
fuweng11 commented on code in PR #8028: URL: https://github.com/apache/inlong/pull/8028#discussion_r1194552719 ## inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java: ## @@ -138,11 +144,30 @@ public class AgentServiceImp

[GitHub] [inlong] EMsnap opened a new pull request, #8030: [INLONG-8029][Sort] use fixed subscription name when start a pulsar reader

2023-05-15 Thread via GitHub
EMsnap opened a new pull request, #8030: URL: https://github.com/apache/inlong/pull/8030 ### Prepare a Pull Request - Fixes #8029 ### Motivation Fixes #8029 ### Modifications use fixed subscription name when starting a pulsar reader see https://github.com/

[GitHub] [inlong] gong commented on pull request #8030: [INLONG-8029][Sort] Use fixed subscription name when start a pulsar reader

2023-05-15 Thread via GitHub
gong commented on PR #8030: URL: https://github.com/apache/inlong/pull/8030#issuecomment-1548928330 @EMsnap Will it be ok when old task restart? -- 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 th

[GitHub] [inlong] EMsnap commented on pull request #8030: [INLONG-8029][Sort] Use fixed subscription name when start a pulsar reader

2023-05-15 Thread via GitHub
EMsnap commented on PR #8030: URL: https://github.com/apache/inlong/pull/8030#issuecomment-1548932236 > @EMsnap Will it be ok when old task restart? the pulsar connector use reader rather than consumer is for the reason that reader can reset cursor manually which is suitable for s

[GitHub] [inlong] dockerzhang merged pull request #8028: [INLONG-8021][Manager] Periodically delete sources with inconsistent states

2023-05-15 Thread via GitHub
dockerzhang merged PR #8028: URL: https://github.com/apache/inlong/pull/8028 -- 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-8021][Manager] Periodically delete sources with inconsistent states (#8028)

2023-05-15 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 7f802898c [INLONG-8021][Manager] Periodical

[inlong] branch branch-1.7 updated: [INLONG-8021][Manager] Periodically delete sources with inconsistent states (#8028)

2023-05-15 Thread dockerzhang
This is an automated email from the ASF dual-hosted git repository. dockerzhang pushed a commit to branch branch-1.7 in repository https://gitbox.apache.org/repos/asf/inlong.git The following commit(s) were added to refs/heads/branch-1.7 by this push: new af6c6c009 [INLONG-8021][Manager] Pe

[GitHub] [inlong] GanfengTan opened a new pull request, #8032: [INLONG-8031][Sort][Manager][Agent] Support to dynamically select flink version packaging

2023-05-15 Thread via GitHub
GanfengTan opened a new pull request, #8032: URL: https://github.com/apache/inlong/pull/8032 Support to dynamically select flink version packaging. 1. The packaging of different versions does not conflict with each other, and the dependent versions are managed by themselves. 2. The

[GitHub] [inlong] EMsnap opened a new pull request, #8033: Branch 1.7

2023-05-15 Thread via GitHub
EMsnap opened a new pull request, #8033: URL: https://github.com/apache/inlong/pull/8033 ### Motivation fix #8029 ### Modifications fix #8029 ### Verifying this change -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [inlong] fuweng11 opened a new pull request, #8037: [INLONG-8035][Manager] Fix Non-file tasks cannot be recovered from the heartbeat timeout state

2023-05-15 Thread via GitHub
fuweng11 opened a new pull request, #8037: URL: https://github.com/apache/inlong/pull/8037 ### Prepare a Pull Request - Fixes #8035 ### Motivation Fix Non-file tasks cannot be recovered from the heartbeat timeout state. ### Modifications Fix Non-fil