aloyszhang commented on PR #9937:
URL: https://github.com/apache/inlong/pull/9937#issuecomment-2041961407
The messages from all clusters are mixed, is it ok?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
luchunliang commented on code in PR #9937:
URL: https://github.com/apache/inlong/pull/9937#discussion_r1555275837
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/QueryLatestMessagesRunnable.java:
##
@@ -0,0 +1,84 @@
+/*
+ *
fuweng11 commented on code in PR #9937:
URL: https://github.com/apache/inlong/pull/9937#discussion_r1555266703
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/QueryLatestMessagesRunnable.java:
##
@@ -0,0 +1,84 @@
+/*
+ * Li
vernedeng commented on code in PR #9937:
URL: https://github.com/apache/inlong/pull/9937#discussion_r1555266770
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/QueryLatestMessagesRunnable.java:
##
@@ -0,0 +1,84 @@
+/*
+ * L
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 da856a4619 [INLONG-9928][Audit] Audit-servic
gosonzhang merged PR #9929:
URL: https://github.com/apache/inlong/pull/9929
--
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
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555240621
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java:
##
@@ -778,4 +825,53 @@ private List fetchTask(TaskRe
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555237624
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ErrorCodeEnum.java:
##
@@ -156,6 +156,13 @@ public enum ErrorCodeEnum {
AUDIT
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555237365
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster nod
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r155523
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ModuleType.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Found
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555237223
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster nod
luchunliang opened a new pull request, #9937:
URL: https://github.com/apache/inlong/pull/9937
### Prepare a Pull Request
- Fixes #9936
### Motivation
When clusterTag have multiple Pulsar clusters and the amount of data is
little, reading the data preview data from only
doleyzi commented on code in PR #9929:
URL: https://github.com/apache/inlong/pull/9929#discussion_r1555213161
##
inlong-audit/audit-service/src/main/java/elector/impl/DBDataSource.java:
##
@@ -0,0 +1,307 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
doleyzi commented on code in PR #9929:
URL: https://github.com/apache/inlong/pull/9929#discussion_r1555211590
##
inlong-audit/audit-service/src/main/java/elector/impl/DBDataSource.java:
##
@@ -0,0 +1,307 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
vernedeng commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555188990
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java:
##
@@ -778,4 +825,53 @@ private List fetchTask(TaskR
vernedeng commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555185807
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster no
aloyszhang commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555185838
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ModuleType.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Fou
aloyszhang commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555184898
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ErrorCodeEnum.java:
##
@@ -156,6 +156,13 @@ public enum ErrorCodeEnum {
AUD
vernedeng commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555183717
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster no
vernedeng commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555183806
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster no
vernedeng commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555182469
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster no
vernedeng commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1555182469
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/agent/AgentClusterNodeDTO.java:
##
@@ -42,16 +50,57 @@
@ApiModel("Agent cluster no
aloyszhang merged PR #9935:
URL: https://github.com/apache/inlong/pull/9935
--
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
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 1df84dca9f [INLONG-9934][doc] update copyrig
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 9b5999764a [INLONG-9926][Audit] Audit-servic
gosonzhang merged PR #9927:
URL: https://github.com/apache/inlong/pull/9927
--
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
aloyszhang opened a new pull request, #9935:
URL: https://github.com/apache/inlong/pull/9935
- Fixes #9934
### Motivation
Copyright in NOTICE is still 2019-2023, which needs updating.
### Modifications
update Copyright in NOTICE to 2024
### Verifying this c
fuweng11 commented on issue #8870:
URL: https://github.com/apache/inlong/issues/8870#issuecomment-2041456765
This issue has been fixed in version 1.11.0.
--
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
fuweng11 commented on issue #8870:
URL: https://github.com/apache/inlong/issues/8870#issuecomment-2041456820
This issue has been fixed in version 1.11.0.
--
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
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 49932d6f59 [INLONG-9922][Agent] Add a scrip
dockerzhang merged PR #9923:
URL: https://github.com/apache/inlong/pull/9923
--
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.
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554943565
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java:
##
@@ -778,4 +825,53 @@ private List fetchTask(TaskRe
justinwwhuang commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554928302
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java:
##
@@ -778,4 +825,53 @@ private List fetchTask(T
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554889296
##
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/InstallerCode.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation
justinwwhuang commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554855217
##
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/InstallerCode.java:
##
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Founda
gosonzhang commented on code in PR #9927:
URL: https://github.com/apache/inlong/pull/9927#discussion_r1554855940
##
inlong-audit/audit-service/src/main/java/elector/task/DBMonitorTask.java:
##
@@ -0,0 +1,66 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554854698
##
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/InstallerCode.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation
aloyszhang commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554851292
##
inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/installer/InstallerCode.java:
##
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundatio
fuweng11 commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554846870
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ModuleType.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Found
aloyszhang commented on code in PR #9933:
URL: https://github.com/apache/inlong/pull/9933#discussion_r1554845119
##
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ModuleType.java:
##
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Fou
doleyzi commented on code in PR #9927:
URL: https://github.com/apache/inlong/pull/9927#discussion_r1554842036
##
inlong-audit/audit-service/src/main/java/elector/task/DBMonitorTask.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
fuweng11 opened a new pull request, #9933:
URL: https://github.com/apache/inlong/pull/9933
### Prepare a Pull Request
- Fixes #9932
### Motivation
Add an agent installer module management for agent installation.
### Modifications
Add an agent install
doleyzi commented on code in PR #9927:
URL: https://github.com/apache/inlong/pull/9927#discussion_r1554841802
##
inlong-audit/audit-service/src/main/java/elector/api/ElectorConfig.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
doleyzi commented on code in PR #9927:
URL: https://github.com/apache/inlong/pull/9927#discussion_r1554841149
##
inlong-audit/audit-service/src/main/java/elector/api/Elector.java:
##
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ *
baomingyu commented on code in PR #9927:
URL: https://github.com/apache/inlong/pull/9927#discussion_r1554832058
##
inlong-audit/audit-service/src/main/java/elector/api/ElectorConfig.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
baomingyu commented on code in PR #9929:
URL: https://github.com/apache/inlong/pull/9929#discussion_r1554827785
##
inlong-audit/audit-service/src/main/java/elector/impl/ElectorImpl.java:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
46 matches
Mail list logo
