Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-12 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756285460 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756120543 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756115922 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756154385 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Software

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756115922 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756145612 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Software

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756138334 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,279 @@ package org.apache.inlong.agent.plugin

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756137158 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,279 @@ package org.apache.inlong.agent.plugin

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756136763 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Software

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756120543 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756115922 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
justinwwhuang commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756102202 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +321,272 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
justinwwhuang commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756099335 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,279 @@ package org.apache.inlong.agent.p

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
justinwwhuang commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756095808 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,279 @@ package org.apache.inlong.agent.p

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
aloyszhang commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756081863 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Softwar

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
aloyszhang commented on code in PR #11084: URL: https://github.com/apache/inlong/pull/11084#discussion_r1756081633 ## inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Softwar

[PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO opened a new pull request, #11084: URL: https://github.com/apache/inlong/pull/11084 Fixes #10287 ### Motivation this pull request is a enhancement of the previous pr #10801 Complete the task requirement mentioned in pr #10801 * Two modes are provide

[PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO opened a new pull request, #11083: URL: https://github.com/apache/inlong/pull/11083 Fixes #10287 ### Motivation this pull request is a enhancement of the previous pr #10801 Complete the task requirement mentioned in pr #10801 * Two modes are provide

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-11 Thread via GitHub
emptyOVO closed pull request #11083: [INLONG-10287][Agent] Update the Redis Source URL: https://github.com/apache/inlong/pull/11083 -- 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 comme

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-02 Thread via GitHub
emptyOVO closed pull request #10801: [INLONG-10287][Agent] Update the Redis Source URL: https://github.com/apache/inlong/pull/10801 -- 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 comm

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-02 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1740891986 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +182,96 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-01 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1740293566 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +182,96 @@ public boolean sourceFinish() { @Ov

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-09-01 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1740268402 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +182,96 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-29 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1735782184 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,169 @@ package org.apache.inlong.agent.plugin

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-28 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1735556446 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -17,54 +17,169 @@ package org.apache.inlong.agent.p

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-27 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1732403961 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +182,96 @@ public boolean sourceFinish() { @Ov

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-26 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1732065544 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +182,96 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-26 Thread via GitHub
emptyOVO commented on PR #10801: URL: https://github.com/apache/inlong/pull/10801#issuecomment-2309817614 > @emptyOVO please click `resolve` if you fix the comment, and you do not need to open/close the PR again and again. got it -- This is an automated message from the Apache Git

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-25 Thread via GitHub
dockerzhang commented on PR #10801: URL: https://github.com/apache/inlong/pull/10801#issuecomment-2309267266 @emptyOVO please click `resolve` if you fix the comment, and you do not need to open/close the PR again and again. -- This is an automated message from the Apache Git Service. To r

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-22 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1726709878 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-22 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1726648380 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-21 Thread via GitHub
emptyOVO closed pull request #10801: [INLONG-10287][Agent] Update the Redis Source URL: https://github.com/apache/inlong/pull/10801 -- 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 comm

[PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-21 Thread via GitHub
emptyOVO opened a new pull request, #10801: URL: https://github.com/apache/inlong/pull/10801 Fixes https://github.com/apache/inlong/issues/10287 ## Motivation Update the Redis source for agent ## Modifications Modify TaskProfileDto and RedisTask to accept and parse the con

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-21 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1725479053 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-20 Thread via GitHub
emptyOVO closed pull request #10801: [INLONG-10287][Agent] Update the Redis Source URL: https://github.com/apache/inlong/pull/10801 -- 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 comm

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-20 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1724367032 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-20 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1724194966 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-20 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1721832043 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-19 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1721832043 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-19 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1721832043 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-19 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1721751409 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -84,6 +181,278 @@ public boolean sourceFinish() {

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-18 Thread via GitHub
emptyOVO commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1721275919 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -74,7 +162,18 @@ protected boolean isRunnable() { @O

Re: [PR] [INLONG-10287][Agent] Update the Redis Source [inlong]

2024-08-18 Thread via GitHub
justinwwhuang commented on code in PR #10801: URL: https://github.com/apache/inlong/pull/10801#discussion_r1721253191 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java: ## @@ -74,7 +162,18 @@ protected boolean isRunnable() {