EMsnap merged PR #9086:
URL: https://github.com/apache/inlong/pull/9086
--
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
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 47c7c78b28 [INLONG-9083][SDK] Bump up x/net modu
github-actions[bot] commented on issue #8651:
URL: https://github.com/apache/inlong/issues/8651#issuecomment-1774306992
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
castorqin commented on code in PR #9067:
URL: https://github.com/apache/inlong/pull/9067#discussion_r1368055867
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/pulsar/PulsarSinkOperator.java:
##
@@ -123,7 +123,8 @@ public Map parse2IdParams
castorqin commented on code in PR #9067:
URL: https://github.com/apache/inlong/pull/9067#discussion_r1368055976
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java:
##
@@ -278,6 +292,18 @@ private List>
parseId
fuweng11 commented on code in PR #9067:
URL: https://github.com/apache/inlong/pull/9067#discussion_r1368081385
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsOperator.java:
##
@@ -55,26 +56,28 @@
@Service
public class Cls
castorqin commented on code in PR #9067:
URL: https://github.com/apache/inlong/pull/9067#discussion_r1368083458
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsOperator.java:
##
@@ -55,26 +56,28 @@
@Service
public class Cl
aloyszhang commented on code in PR #8941:
URL: https://github.com/apache/inlong/pull/8941#discussion_r1368139050
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/queue/pulsar/PulsarPartitionedInternalStats.java:
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to
aloyszhang commented on code in PR #8941:
URL: https://github.com/apache/inlong/pull/8941#discussion_r1368182513
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java:
##
@@ -39,54 +51,420 @@ public class PulsarU
