Re: [PR] [INLONG-11595][SDK] Optimize the implementation of node connection management [inlong]

2024-12-10 Thread via GitHub
fuweng11 commented on code in PR #11596: URL: https://github.com/apache/inlong/pull/11596#discussion_r1879495714 ## inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/NettyClient.java: ## @@ -19,107 +19,115 @@ import org.apache.inlong.sdk.dataproxy

(inlong) branch master updated: [INLONG-11591][Agent] Reduce duplicate code for log collection type tasks (#11592)

2024-12-10 Thread wenweihuang
This is an automated email from the ASF dual-hosted git repository. wenweihuang 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 4d597adee0 [INLONG-11591][Agent] Reduce dup

Re: [PR] [INLONG-11591][Agent] Reduce duplicate code for log collection type tasks [inlong]

2024-12-10 Thread via GitHub
justinwwhuang merged PR #11592: URL: https://github.com/apache/inlong/pull/11592 -- 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...@inl

Re: [PR] [INLONG-11591][Agent] Reduce duplicate code for log collection type tasks [inlong]

2024-12-10 Thread via GitHub
justinwwhuang commented on code in PR #11592: URL: https://github.com/apache/inlong/pull/11592#discussion_r1877661420 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/FormatDateLogFileTask.java: ## @@ -17,11 +17,11 @@ package org.apache.inlong.a

(inlong) branch master updated: [INLONG-11592][SDK] Suppress info logs in Golang SDK (#11594)

2024-12-10 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 4fa6583e8c [INLONG-11592][SDK] Suppress info

Re: [PR] [INLONG-11592][SDK] Suppress info logs in Golang SDK [inlong]

2024-12-10 Thread via GitHub
aloyszhang merged PR #11594: URL: https://github.com/apache/inlong/pull/11594 -- 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-11591][Agent] Reduce duplicate code for log collection type tasks [inlong]

2024-12-10 Thread via GitHub
aloyszhang commented on code in PR #11592: URL: https://github.com/apache/inlong/pull/11592#discussion_r1877628682 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/FormatDateLogFileTask.java: ## @@ -17,11 +17,11 @@ package org.apache.inlong.agen

Re: [PR] [INLONG-11591][Agent] Reduce duplicate code for log collection type tasks [inlong]

2024-12-10 Thread via GitHub
aloyszhang commented on code in PR #11592: URL: https://github.com/apache/inlong/pull/11592#discussion_r1877635018 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java: ## @@ -453,7 +453,7 @@ private void addToMemory(InstanceProfile

Re: [PR] [INLONG-11349][Sort] Integrate opentelemetry for sort-connectors-v1.15 [inlong]

2024-12-10 Thread via GitHub
qy-liuhuo commented on PR #11351: URL: https://github.com/apache/inlong/pull/11351#issuecomment-2531585839 > Thanks for your contribution. Sorry, but If we don't use the open telemetry, why do we initialize it in the open method? Maybe adding a new configuration to enable open telemetry is

[PR] [INLONG-11595][SDK] Optimize the implementation of node connection management [inlong]

2024-12-10 Thread via GitHub
gosonzhang opened a new pull request, #11596: URL: https://github.com/apache/inlong/pull/11596 Fixes #11595 1. Adjust the proxy node selection algorithm, adopt random selection and regularly update the reselection mechanism; 2. Add reconnection processing to NettyClient;