Author: wakefu
Date: Sun Jul 28 18:13:13 2024
New Revision: 70591
Log:
add gpg key for wakefu
Modified:
dev/inlong/KEYS
Modified: dev/inlong/KEYS
==
--- dev/inlong/KEYS (original)
+++ dev/inlong/KEYS Sun Jul 28 18:13
Author: wakefu
Date: Sun Jul 28 18:20:07 2024
New Revision: 70592
Log:
prepare for 1.13.0 RC0
Added:
dev/inlong/1.13.0-RC0/
dev/inlong/1.13.0-RC0/apache-inlong-1.13.0-bin.tar.gz (with props)
dev/inlong/1.13.0-RC0/apache-inlong-1.13.0-bin.tar.gz.asc
dev/inlong/1.13.0-RC0/apache-i
xxsc0529 commented on code in PR #10701:
URL: https://github.com/apache/inlong/pull/10701#discussion_r1694412857
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/oceanbase/OceanBaseSourceOperator.java:
##
@@ -0,0 +1,124 @@
+/*
+ * Licensed
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 ab543f86c0 [INLONG-10723][Manager] Update base64 encoder (#10724)
add 0b50e298e2 [INLONG-10704][Sort] Sort A
dockerzhang merged PR #10700:
URL: https://github.com/apache/inlong/pull/10700
--
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...@inlon
Author: wakefu
Date: Mon Jul 29 02:47:00 2024
New Revision: 70596
Log:
add gpg key for wakefu
Modified:
dev/inlong/KEYS
Modified: dev/inlong/KEYS
==
--- dev/inlong/KEYS (original)
+++ dev/inlong/KEYS Mon Jul 29 02:47
xxsc0529 commented on PR #10701:
URL: https://github.com/apache/inlong/pull/10701#issuecomment-2254849640
> @xxsc0529 please fix the failed workflow and comments, thanks.
This codeQL doesn't work.,The same logic as mysql here.,I can't detect a lot
of the original code here.,Do you hav
Author: dockerzhang
Date: Mon Jul 29 03:16:10 2024
New Revision: 70597
Log:
add gpg key for wakefu
Modified:
release/inlong/KEYS
Modified: release/inlong/KEYS
==
--- release/inlong/KEYS (original)
+++ release/inlong/
fuweng11 commented on code in PR #10701:
URL: https://github.com/apache/inlong/pull/10701#discussion_r1694481335
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/oceanbase/OceanBaseBinlogSourceRequest.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed
vernedeng commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694558122
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java:
##
@@ -20,63 +20,57 @@
import org.apache.inlong.agent.conf.Insta
vernedeng commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694559483
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java:
##
@@ -20,63 +20,57 @@
import org.apache.inlong.agent.conf.Insta
vernedeng commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694560301
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java:
##
@@ -87,27 +81,51 @@ protected String getThreadName() {
vernedeng commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694561750
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java:
##
@@ -246,4 +237,26 @@ public void destroy() {
vernedeng commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694562488
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/MqttTask.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Software Foundation
vernedeng commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694563205
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/MqttTask.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Software Foundation
xxsc0529 commented on code in PR #10701:
URL: https://github.com/apache/inlong/pull/10701#discussion_r1694598940
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/oceanbase/OceanBaseBinlogSource.java:
##
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the
xxsc0529 commented on code in PR #10701:
URL: https://github.com/apache/inlong/pull/10701#discussion_r1694600687
##
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/oceanbase/OceanBaseBinlogSourceRequest.java:
##
@@ -0,0 +1,123 @@
+/*
+ * Licensed
aloyszhang commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694628418
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java:
##
@@ -20,63 +20,57 @@
import org.apache.inlong.agent.conf.Inst
aloyszhang commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694630633
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java:
##
@@ -88,22 +77,22 @@ public MqttReader(String topic) {
aloyszhang commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694630633
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java:
##
@@ -88,22 +77,22 @@ public MqttReader(String topic) {
aloyszhang commented on code in PR #10727:
URL: https://github.com/apache/inlong/pull/10727#discussion_r1694632543
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/MqttReader.java:
##
@@ -147,6 +137,7 @@ public void deliveryComplete(IMqtt
qy-liuhuo commented on PR #10727:
URL: https://github.com/apache/inlong/pull/10727#issuecomment-2255089171
I have fixed these issues, please review again, thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
22 matches
Mail list logo
