Re: [I] [Feature][Sort] Add Redis connector on flink 1.15 [inlong]

2023-11-19 Thread via GitHub
github-actions[bot] commented on issue #8948: URL: https://github.com/apache/inlong/issues/8948#issuecomment-1818087038 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

[PR] [INLONG-9308][Agent] The sink end of the file instance supports sending data with different streamIds [inlong]

2023-11-19 Thread via GitHub
justinwwhuang opened a new pull request, #9309: URL: https://github.com/apache/inlong/pull/9309 [INLONG-9308][Agent] The sink end of the file instance supports sending data with different streamIds - Fixes #9308 ### Motivation The sink end of the file instance supports send

Re: [PR] [INLONG-9285][Manager] When creating KafkaSource, the autoOffsetReset param cannot be empty [inlong]

2023-11-19 Thread via GitHub
dockerzhang merged PR #9287: URL: https://github.com/apache/inlong/pull/9287 -- 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-9285][Manager] When creating KafkaSource, the autoOffsetReset param cannot be empty (#9287)

2023-11-19 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 47ff34981b [INLONG-9285][Manager] When crea

Re: [PR] [INLONG-9297][Manager] Support configuring multiple sink types of tasks under a single stream [inlong]

2023-11-19 Thread via GitHub
healchow commented on code in PR #9298: URL: https://github.com/apache/inlong/pull/9298#discussion_r1398636241 ## inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java: ## @@ -39,4 +45,23 @@ public class SinkType extends StreamType {

Re: [PR] [INLONG-9302][Dashboard] Elasticsearch sink optimization [inlong]

2023-11-19 Thread via GitHub
dockerzhang merged PR #9304: URL: https://github.com/apache/inlong/pull/9304 -- 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 (47ff34981b -> 4b1c46ad7b)

2023-11-19 Thread dockerzhang
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 47ff34981b [INLONG-9285][Manager] When creating KafkaSource, the autoOffsetReset param cannot be empty (#9287)

Re: [PR] [INLONG-9308][Agent] The sink end of the file instance supports sending data with different streamIds [inlong]

2023-11-19 Thread via GitHub
EMsnap commented on code in PR #9309: URL: https://github.com/apache/inlong/pull/9309#discussion_r1398747690 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -74,16 +71,15 @@ public class ProxyMessageCache {

Re: [PR] [INLONG-9308][Agent] The sink end of the file instance supports sending data with different streamIds [inlong]

2023-11-19 Thread via GitHub
justinwwhuang commented on code in PR #9309: URL: https://github.com/apache/inlong/pull/9309#discussion_r1398753922 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessage.java: ## @@ -0,0 +1,100 @@ +/* + * Licensed to the Apache Softw

Re: [PR] [INLONG-9308][Agent] The sink end of the file instance supports sending data with different streamIds [inlong]

2023-11-19 Thread via GitHub
justinwwhuang commented on code in PR #9309: URL: https://github.com/apache/inlong/pull/9309#discussion_r1398754598 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -74,16 +71,15 @@ public class ProxyMessageCach

Re: [PR] [INLONG-9308][Agent] The sink end of the file instance supports sending data with different streamIds [inlong]

2023-11-19 Thread via GitHub
luchunliang merged PR #9309: URL: https://github.com/apache/inlong/pull/9309 -- 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-9308][Agent] The sink end of the file instance supports sending data with different streamIds (#9309)

2023-11-19 Thread luchunliang
This is an automated email from the ASF dual-hosted git repository. luchunliang 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 c3bdf56a92 [INLONG-9308][Agent] The sink en