Re: [PR] [INLONG-8674][Manager] Pulsar - Modify the calling method from SDK to HTTP [inlong]

2023-10-23 Thread via GitHub
aloyszhang commented on code in PR #8941: URL: https://github.com/apache/inlong/pull/8941#discussion_r1368320380 ## inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/queue/PulsarUtilsTest.java: ## @@ -17,39 +17,161 @@ package org.apache.inlong.man

[PR] [Improve][Sort] TubeMQ Connector use latest offset mode [inlong]

2023-10-23 Thread via GitHub
vernedeng opened a new pull request, #9088: URL: https://github.com/apache/inlong/pull/9088 ### 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 replac

Re: [PR] [INLONG-9087][Sort] TubeMQ Connector use latest offset mode [inlong]

2023-10-23 Thread via GitHub
EMsnap commented on PR #9088: URL: https://github.com/apache/inlong/pull/9088#issuecomment-1774770237 please change tube source in flink 1.13 as well -- 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

Re: [PR] [INLONG-9087][Sort] TubeMQ Connector use latest offset mode [inlong]

2023-10-23 Thread via GitHub
vernedeng commented on PR #9088: URL: https://github.com/apache/inlong/pull/9088#issuecomment-1774772131 > please change tube source in flink 1.13 as well done -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [INLONG-9087][Sort] TubeMQ Connector use latest offset mode [inlong]

2023-10-23 Thread via GitHub
dockerzhang merged PR #9088: URL: https://github.com/apache/inlong/pull/9088 -- 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-9087][Sort] TubeMQ Connector use latest offset mode (#9088)

2023-10-23 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 a0b69d6f58 [INLONG-9087][Sort] TubeMQ Conne

[PR] [INLONG-9089][agent]Add enums for task and instance [inlong]

2023-10-23 Thread via GitHub
justinwwhuang opened a new pull request, #9090: URL: https://github.com/apache/inlong/pull/9090 ### Prepare a Pull Request - [INLONG-9089][Agent] Add enums for task and instance - Fixes #9089 ### Motivation *in this agent reconfiguration, we will abandon the concept o

Re: [PR] [INLONG-8674][Manager] Pulsar - Modify the calling method from SDK to HTTP [inlong]

2023-10-23 Thread via GitHub
aloyszhang commented on code in PR #8941: URL: https://github.com/apache/inlong/pull/8941#discussion_r1368139050 ## inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/queue/pulsar/PulsarPartitionedInternalStats.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to

Re: [PR] [INLONG-7072][Manager][Sort] Resource adaptive adjustment for Hudi [inlong]

2023-10-23 Thread via GitHub
github-actions[bot] commented on PR #7077: URL: https://github.com/apache/inlong/pull/7077#issuecomment-1776336787 This PR 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 log on t

[PR] [INLONG-9092][Manager] Tube supports inlong-msg format [inlong]

2023-10-23 Thread via GitHub
fuweng11 opened a new pull request, #9093: URL: https://github.com/apache/inlong/pull/9093 ### Prepare a Pull Request - Fixes #9092 ### Motivation Tube supports inlong-msg format. ### Modifications Tube supports inlong-msg format. -- This is an au

Re: [PR] [INLONG-9089][Agent] Add enums for task and instance [inlong]

2023-10-23 Thread via GitHub
EMsnap commented on code in PR #9090: URL: https://github.com/apache/inlong/pull/9090#discussion_r1369473131 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to the Apache Software Foundation (A

Re: [PR] [INLONG-9089][Agent] Add enums for task and instance [inlong]

2023-10-23 Thread via GitHub
justinwwhuang commented on code in PR #9090: URL: https://github.com/apache/inlong/pull/9090#discussion_r1369477462 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java: ## @@ -0,0 +1,218 @@ +/* + * Licensed to the Apache Software Founda

Re: [PR] [INLONG-9073][Manager] Add getStreamBriefInfo method for InlongStreamClient [inlong]

2023-10-23 Thread via GitHub
EMsnap commented on code in PR #9074: URL: https://github.com/apache/inlong/pull/9074#discussion_r1369483512 ## inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java: ## @@ -107,6 +107,23 @@ public InlongStreamInfo

[inlong] branch master updated: [INLONG-9089][Agent] Add enums for task and instance (#9090)

2023-10-23 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 e5ba995f75 [INLONG-9089][Agent] Add enums f

Re: [PR] [INLONG-9089][Agent] Add enums for task and instance [inlong]

2023-10-23 Thread via GitHub
dockerzhang merged PR #9090: URL: https://github.com/apache/inlong/pull/9090 -- 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-9060][Manager] Fix manager return wrong sink configuration to sort standalone [inlong]

2023-10-23 Thread via GitHub
dockerzhang merged PR #9067: URL: https://github.com/apache/inlong/pull/9067 -- 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-9060][Manager] Fix manager return wrong sink configuration to sort standalone (#9067)

2023-10-23 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 292bbb7547 [INLONG-9060][Manager] Fix manag