[PR] [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path [inlong]

justinwwhuang opened a new pull request, #9118: URL: https://github.com/apache/inlong/pull/9118 ### Prepare a Pull Request [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path - Fixes #9117 ### Motivation *Agent will have more th

Re: [PR] [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path [inlong]

justinwwhuang closed pull request #9118: [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path URL: https://github.com/apache/inlong/pull/9118 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[PR] [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path [inlong]

justinwwhuang opened a new pull request, #9119: URL: https://github.com/apache/inlong/pull/9119 ### Prepare a Pull Request [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path - Fixes #9117 ### Motivation *Agent will have more th

Re: [PR] [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path [inlong]

EMsnap commented on code in PR #9119: URL: https://github.com/apache/inlong/pull/9119#discussion_r1372790982 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/RocksDbImp.java: ## @@ -160,23 +160,12 @@ public KeyValueEntity get(String key) { @Override

Re: [PR] [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path [inlong]

justinwwhuang commented on code in PR #9119: URL: https://github.com/apache/inlong/pull/9119#discussion_r1372801494 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/RocksDbImp.java: ## @@ -160,23 +160,12 @@ public KeyValueEntity get(String key) { @Ove

Re: [PR] [INLONG-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path [inlong]

dockerzhang merged PR #9119: URL: https://github.com/apache/inlong/pull/9119 -- 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-9117][Agent] Rewrite class RocksDbImp to enable it to be constructed with a child path (#9119)

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 a194f575f9 [INLONG-9117][Agent] Rewrite cla

[PR] [INLONG-9120][Agent] Add offset db to store the offset data [inlong]

justinwwhuang opened a new pull request, #9121: URL: https://github.com/apache/inlong/pull/9121 ### Prepare a Pull Request [INLONG-9120][Agent] Add offset db to store the offset data - Fixes #9120 ### Motivation Add offset db to store the offset data ### Modifi

Re: [PR] [INLONG-9120][Agent] Add offset db to store the offset data [inlong]

EMsnap commented on code in PR #9121: URL: https://github.com/apache/inlong/pull/9121#discussion_r1372872777 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java: ## @@ -61,8 +61,8 @@ public class CommonConstants { // the same tas

Re: [PR] [INLONG-9120][Agent] Add offset db to store the offset data [inlong]

justinwwhuang commented on code in PR #9121: URL: https://github.com/apache/inlong/pull/9121#discussion_r1372908491 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java: ## @@ -61,8 +61,8 @@ public class CommonConstants { // the s

[PR] [INLONG-9122][Agent] Add task and instance action [inlong]

justinwwhuang opened a new pull request, #9123: URL: https://github.com/apache/inlong/pull/9123 ### Prepare a Pull Request [INLONG-9122][Agent] Add task and instance action - Fixes #9122 ### Motivation To manage task and instance agent define different action #

Re: [PR] [INLONG-9122][Agent] Add task and instance action [inlong]

luchunliang merged PR #9123: URL: https://github.com/apache/inlong/pull/9123 -- 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-9122][Agent] Add task and instance action (#9123)

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 636822bbaf [INLONG-9122][Agent] Add task an

Re: [PR] [INLONG-9120][Agent] Add offset db to store the offset data [inlong]

luchunliang merged PR #9121: URL: https://github.com/apache/inlong/pull/9121 -- 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 (636822bbaf -> 3ee9921001)

This is an automated email from the ASF dual-hosted git repository. luchunliang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 636822bbaf [INLONG-9122][Agent] Add task and instance action (#9123) add 3ee9921001 [INLONG-9120][Agent] Add

[PR] [INLONG-9128][Sort] Failed to init TubeMQ source with InlongMsg type message [inlong]

vernedeng opened a new pull request, #9129: URL: https://github.com/apache/inlong/pull/9129 ### 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 b

[PR] [INLONG-9124][Agent] Add task and instance db [inlong]

justinwwhuang opened a new pull request, #9130: URL: https://github.com/apache/inlong/pull/9130 ### Prepare a Pull Request [INLONG-9124][Agent] Add task and instance db - Fixes #9124 ### Motivation Add task and instance db ### Modifications Add task and

[PR] [INLONG-9125][Agent] Add offset manager [inlong]

justinwwhuang opened a new pull request, #9131: URL: https://github.com/apache/inlong/pull/9131 ### Prepare a Pull Request [INLONG-9125][Agent] Add offset manager - Fixes #9125 ### Motivation Using offset db to manage offset and make it singleton ### Modificati

Re: [PR] [INLONG-9128][Sort] Failed to init TubeMQ source with InlongMsg type message [inlong]

EMsnap commented on code in PR #9129: URL: https://github.com/apache/inlong/pull/9129#discussion_r1373055815 ## inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java: ## @@ -109,7 +109,7 @@

Re: [PR] [INLONG-9124][Agent] Add task and instance db [inlong]

EMsnap commented on code in PR #9130: URL: https://github.com/apache/inlong/pull/9130#discussion_r1373058566 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/InstanceDb.java: ## @@ -0,0 +1,112 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under

Re: [PR] [INLONG-9125][Agent] Add offset manager [inlong]

EMsnap commented on code in PR #9131: URL: https://github.com/apache/inlong/pull/9131#discussion_r1373061951 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java: ## @@ -0,0 +1,76 @@ +/* + * Licensed to the Apache Software Foundation (ASF

Re: [PR] [INLONG-9125][Agent] Add offset manager [inlong]

EMsnap commented on code in PR #9131: URL: https://github.com/apache/inlong/pull/9131#discussion_r1373061951 ## inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java: ## @@ -0,0 +1,76 @@ +/* + * Licensed to the Apache Software Foundation (ASF

[PR] [INLONG-9132][Agent] Add file used message cache [inlong]

justinwwhuang opened a new pull request, #9133: URL: https://github.com/apache/inlong/pull/9133 ### Prepare a Pull Request [INLONG-9132][Agent] Add file used message cache - Fixes #9132 ### Motivation To make the file used message cache independent from common cache

Re: [PR] [INLONG-9126][Manager] Fix the problem of unable to modify the responsible person of the group [inlong]

dockerzhang merged PR #9127: URL: https://github.com/apache/inlong/pull/9127 -- 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-9126][Manager] Fix the problem of unable to modify the responsible person of the group (#9127)

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 e4b22ce94a [INLONG-9126][Manager] Fix the p

Re: [PR] [INLONG-9128][Sort] Failed to init TubeMQ source with InlongMsg type message [inlong]

vernedeng commented on code in PR #9129: URL: https://github.com/apache/inlong/pull/9129#discussion_r1373264493 ## inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java: ## @@ -109,7 +109,7

Re: [PR] [INLONG-9125][Agent] Add offset manager [inlong]

dockerzhang merged PR #9131: URL: https://github.com/apache/inlong/pull/9131 -- 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-9125][Agent] Add offset manager (#9131)

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 08fca3a456 [INLONG-9125][Agent] Add offset

[inlong] branch master updated: [INLONG-9124][Agent] Add task and instance db (#9130)

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 d1cd775e16 [INLONG-9124][Agent] Add task an

Re: [PR] [INLONG-9124][Agent] Add task and instance db [inlong]

dockerzhang merged PR #9130: URL: https://github.com/apache/inlong/pull/9130 -- 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: [I] [Feature][Metrics][TubeMQ] Add grafana dashboard json template [inlong]

github-actions[bot] commented on issue #6756: URL: https://github.com/apache/inlong/issues/6756#issuecomment-1782164179 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

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

luchunliang commented on code in PR #9133: URL: https://github.com/apache/inlong/pull/9133#discussion_r1373991178 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache So

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

justinwwhuang commented on code in PR #9133: URL: https://github.com/apache/inlong/pull/9133#discussion_r1373994808 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

EMsnap commented on code in PR #9133: URL: https://github.com/apache/inlong/pull/9133#discussion_r1373997847 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Softwar

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

justinwwhuang commented on code in PR #9133: URL: https://github.com/apache/inlong/pull/9133#discussion_r1374000255 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

EMsnap commented on code in PR #9133: URL: https://github.com/apache/inlong/pull/9133#discussion_r1374000840 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache Softwar

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

justinwwhuang commented on code in PR #9133: URL: https://github.com/apache/inlong/pull/9133#discussion_r1374003564 ## inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/filecollect/ProxyMessageCache.java: ## @@ -0,0 +1,184 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-9132][Agent] Add file used message cache [inlong]

EMsnap merged PR #9133: URL: https://github.com/apache/inlong/pull/9133 -- 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.apach

[inlong] branch master updated: [INLONG-9132][Agent] Add file used message cache (#9133)

This is an automated email from the ASF dual-hosted git repository. zirui 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 2f90ca43fe [INLONG-9132][Agent] Add file used mes

[inlong] branch master updated: [INLONG-9128][Sort] Fix the failed to init TubeMQ source with InlongMsg type message (#9129)

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 0278f0c143 [INLONG-9128][Sort] Fix the fail

Re: [PR] [INLONG-9128][Sort] Failed to init TubeMQ source with InlongMsg type message [inlong]

dockerzhang merged PR #9129: URL: https://github.com/apache/inlong/pull/9129 -- 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.

[PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang opened a new pull request, #9135: URL: https://github.com/apache/inlong/pull/9135 ### Prepare a Pull Request [INLONG-9134][Agent] Add file related utils - Fixes #9134 ### Motivation Add file related utils ### Modifications Add file related

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

doleyzi commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374029015 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/MatchPoint.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the Apache Software Founda

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374033149 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/MatchPoint.java: ## @@ -0,0 +1,58 @@ +/* + * Licensed to the Apache Software

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

dockerzhang merged PR #9093: URL: https://github.com/apache/inlong/pull/9093 -- 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 (0278f0c143 -> 2c8c787c89)

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 0278f0c143 [INLONG-9128][Sort] Fix the failed to init TubeMQ source with InlongMsg type message (#9129) add

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

EMsnap commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374035999 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/MatchPoint.java: ## @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374036529 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/FilePathUtil.java: ## @@ -0,0 +1,170 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

EMsnap commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374035999 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/MatchPoint.java: ## @@ -0,0 +1,55 @@ +/* + * Licensed to the Apache Software Foundat

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

EMsnap commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374037001 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,955 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374041612 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,955 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374041518 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/Files.java: ## @@ -0,0 +1,72 @@ +/* + * Licensed to the Apache Software Found

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374042164 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,955 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374056080 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,955 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374056506 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,955 @@ +/* + * Licensed to the Apache Softwa

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

EMsnap commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374110971 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,937 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

justinwwhuang commented on code in PR #9135: URL: https://github.com/apache/inlong/pull/9135#discussion_r1374117968 ## inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/file/NewDateUtils.java: ## @@ -0,0 +1,937 @@ +/* + * Licensed to the Apache Softwa

[inlong] branch master updated: [INLONG-9134][Agent] Add file related utils (#9135)

This is an automated email from the ASF dual-hosted git repository. gosonzhang 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 4f0e0dcd1c [INLONG-9134][Agent] Add file rel

Re: [PR] [INLONG-9134][Agent] Add file related utils [inlong]

gosonzhang merged PR #9135: URL: https://github.com/apache/inlong/pull/9135 -- 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

[PR] [INLONG-9136][Agent] Add instance manager [inlong]

justinwwhuang opened a new pull request, #9137: URL: https://github.com/apache/inlong/pull/9137 ### Prepare a Pull Request [INLONG-9136][Agent] Add instance manager - Fixes #9136 ### Motivation [INLONG-9136][Agent] Add instance manager ### Modifications

Re: [PR] [INLONG-9136][Agent] Add instance manager [inlong]

justinwwhuang closed pull request #9137: [INLONG-9136][Agent] Add instance manager URL: https://github.com/apache/inlong/pull/9137 -- 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 commen