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 f462e67f36 [INLONG-8997][Sort] Keep the logic the
EMsnap merged PR #9040:
URL: https://github.com/apache/inlong/pull/9040
--
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
EMsnap merged PR #9005:
URL: https://github.com/apache/inlong/pull/9005
--
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 change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from f462e67f36 [INLONG-8997][Sort] Keep the logic the same of mysql with
flink v1.13 in end to end test
add a3f8102de
fuweng11 opened a new pull request, #9042:
URL: https://github.com/apache/inlong/pull/9042
### Prepare a Pull Request
- Fixes #9041
### Motivation
Support saving schema information when saving iceberg source.
### Modifications
Support saving schema
EMsnap commented on code in PR #9042:
URL: https://github.com/apache/inlong/pull/9042#discussion_r1354489875
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java:
##
@@ -116,4 +116,11 @@ default Map>
getSourcesMap(In
EMsnap commented on code in PR #9042:
URL: https://github.com/apache/inlong/pull/9042#discussion_r1354508706
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/iceberg/IcebergSourceOperator.java:
##
@@ -83,4 +96,52 @@ public StreamSource get
fuweng11 commented on code in PR #9042:
URL: https://github.com/apache/inlong/pull/9042#discussion_r1354530248
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java:
##
@@ -116,4 +116,11 @@ default Map>
getSourcesMap(
dockerzhang merged PR #9042:
URL: https://github.com/apache/inlong/pull/9042
--
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.
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 a3f8102de2 [INLONG-8695][Sort] Add Pulsar connector based on flink
1.15 (#9005)
add d7459a22cf [INLONG-9041
liaosunny123 opened a new issue, #880:
URL: https://github.com/apache/inlong-website/issues/880
### Description
Add Some Attention in MySQL cdc when using as extract data node and with
version above 8.0
### Are you willing to submit PR?
- [X] Yes, I am willing to submi
liaosunny123 opened a new pull request, #881:
URL: https://github.com/apache/inlong-website/pull/881
### Prepare a Pull Request
- Fixes #880
### Motivation
When using MySQL with version above 8.0, there is a easily caused problem.
And flink error may be hard to find, so
sunrisefromdark commented on code in PR #9012:
URL: https://github.com/apache/inlong/pull/9012#discussion_r1354766922
##
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/topic/TopicWebController.java:
##
@@ -61,47 +68,188 @@ public class Top
dockerzhang closed issue #864: [Improve] Add Redis Sort Connector Document
URL: https://github.com/apache/inlong-website/issues/864
--
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
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-website.git
The following commit(s) were added to refs/heads/master by this push:
new 707a9e05f2 [INLONG-864][Sort] Add r
dockerzhang merged PR #867:
URL: https://github.com/apache/inlong-website/pull/867
--
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...@i
EMsnap merged PR #9035:
URL: https://github.com/apache/inlong/pull/9035
--
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 change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from d7459a22cf [INLONG-9041][Manager] Support saving schema information
when saving iceberg source (#9042)
add 7c5360
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1354806108
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -113,6 +120,32 @@ private void crea
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1354806373
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -152,15 +205,87 @@ private void cre
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1354805736
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -78,32 +90,27 @@ public void create
dockerzhang merged PR #9012:
URL: https://github.com/apache/inlong/pull/9012
--
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.
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 18c39ff593 [INLONG-8961][Manager] Server-si
fancycoderzf closed pull request #879: Update document of TubeMQ extract node
and HBase load node
URL: https://github.com/apache/inlong-website/pull/879
--
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
fancycoderzf opened a new pull request, #882:
URL: https://github.com/apache/inlong-website/pull/882
### Prepare a Pull Request
- Fixes #877
### Motivation
*Update document of TubeMQ extract node*
### Modifications
*Update document of TubeMQ extract node*
fancycoderzf opened a new pull request, #883:
URL: https://github.com/apache/inlong-website/pull/883
### Prepare a Pull Request
- Fixes #878
### Motivation
*Update document of HBase load node.*
### Modifications
*Update document of HBase load node.*
fancycoderzf commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355608274
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/test/java/org/apache/inlong/sort/tubemq/TubeMQConsumerExample.java:
##
@@ -0,0 +1,59 @@
+/*
+
fancycoderzf closed pull request #9032: [INLONG-9009][Sort] Add HBase source
and sink connector on flink 1.15
URL: https://github.com/apache/inlong/pull/9032
--
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 t
fancycoderzf opened a new pull request, #9043:
URL: https://github.com/apache/inlong/pull/9043
### Prepare a Pull Request
- Fixes #9009
### Motivation
*Add HBase source and sink connector on flink 1.15*
### Modifications
*Add HBase source and sink connector
fancycoderzf commented on code in PR #9032:
URL: https://github.com/apache/inlong/pull/9032#discussion_r1355807344
##
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/HBaseSourceSinkTest.java:
##
@@ -0,0 +1,141 @@
+/*
+ * L
fancycoderzf commented on code in PR #9032:
URL: https://github.com/apache/inlong/pull/9032#discussion_r1355807574
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/pom.xml:
##
@@ -0,0 +1,244 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.or
vernedeng commented on code in PR #9011:
URL: https://github.com/apache/inlong/pull/9011#discussion_r1355935370
##
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml:
##
@@ -47,6 +47,17 @@
postgresql
${testcontainers.version}
vernedeng commented on code in PR #9011:
URL: https://github.com/apache/inlong/pull/9011#discussion_r1355935370
##
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml:
##
@@ -47,6 +47,17 @@
postgresql
${testcontainers.version}
vernedeng commented on code in PR #9011:
URL: https://github.com/apache/inlong/pull/9011#discussion_r1355937351
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/pom.xml:
##
@@ -0,0 +1,155 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355945771
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQConsumer.java:
##
@@ -0,0 +1,351 @@
+/*
+ * Li
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355945771
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQConsumer.java:
##
@@ -0,0 +1,351 @@
+/*
+ * Li
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355955162
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQProducer.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Li
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355955162
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQProducer.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Li
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355955663
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQProducer.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Li
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355957604
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQProducer.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Li
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355957703
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQProducer.java:
##
@@ -0,0 +1,178 @@
+/*
+ * Li
EMsnap commented on PR #9043:
URL: https://github.com/apache/inlong/pull/9043#issuecomment-1758798653
Please add some tests on this connector thanks
--
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 t
EMsnap commented on PR #9030:
URL: https://github.com/apache/inlong/pull/9030#issuecomment-1758799085
Please add some tests on this connector thx
--
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
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355962314
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java:
##
@@ -0,0 +1,234 @
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355962611
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java:
##
@@ -0,0 +1,234 @
vernedeng commented on code in PR #9031:
URL: https://github.com/apache/inlong/pull/9031#discussion_r1355962967
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQOptions.java:
##
@@ -0,0 +1,420 @@
+/*
+ * Li
Curry-CPU commented on code in PR #9011:
URL: https://github.com/apache/inlong/pull/9011#discussion_r1355966541
##
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/pom.xml:
##
@@ -47,6 +47,17 @@
postgresql
${testcontainers.version}
vernedeng commented on code in PR #9030:
URL: https://github.com/apache/inlong/pull/9030#discussion_r1355966850
##
inlong-sort/sort-flink/sort-flink-v1.15/pom.xml:
##
@@ -52,9 +52,11 @@
2.7.6
7.2.2.jre8
0.12.3
+3.1.3
0.9.3
2.7
vernedeng commented on code in PR #9030:
URL: https://github.com/apache/inlong/pull/9030#discussion_r1355967518
##
inlong-sort/sort-flink/sort-flink-v1.15/pom.xml:
##
@@ -52,9 +52,11 @@
2.7.6
7.2.2.jre8
0.12.3
+3.1.3
Review Comment:
hive3 v
vernedeng commented on code in PR #9030:
URL: https://github.com/apache/inlong/pull/9030#discussion_r1355968252
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveDynamicTableFactory.java:
##
@@ -0,0 +1,100 @@
+/*
+ * Li
vernedeng commented on code in PR #9030:
URL: https://github.com/apache/inlong/pull/9030#discussion_r1355969155
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-flink-dependencies/pom.xml:
##
@@ -31,49 +31,47 @@
${project.parent.parent.parent.parent.basedir}
+
vernedeng commented on code in PR #9043:
URL: https://github.com/apache/inlong/pull/9043#discussion_r1355970454
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/pom.xml:
##
@@ -0,0 +1,232 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2
vernedeng commented on code in PR #9043:
URL: https://github.com/apache/inlong/pull/9043#discussion_r1355970716
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/pom.xml:
##
@@ -0,0 +1,232 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2
vernedeng commented on code in PR #9011:
URL: https://github.com/apache/inlong/pull/9011#discussion_r1355971788
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/pom.xml:
##
@@ -0,0 +1,155 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1355977648
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -152,15 +205,87 @@ private void cre
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r135593
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -136,14 +169,34 @@ private ClsClien
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1355978140
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -113,6 +120,32 @@ private void crea
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1355978248
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -136,14 +169,34 @@ private ClsClien
castorqin commented on code in PR #9029:
URL: https://github.com/apache/inlong/pull/9029#discussion_r1355978370
##
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java:
##
@@ -136,14 +169,34 @@ private ClsClien
doleyzi opened a new pull request, #9045:
URL: https://github.com/apache/inlong/pull/9045
### Prepare a Pull Request
- Fixes #9044
### Motivation
*Add server response log to facilitate troubleshooting.*
### Modifications
*Add server response log to facilita
dockerzhang merged PR #9045:
URL: https://github.com/apache/inlong/pull/9045
--
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.
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 f197546785 [INLONG-9044][SDK] Add server re
dockerzhang opened a new pull request, #9047:
URL: https://github.com/apache/inlong/pull/9047
### 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 be repl
dockerzhang opened a new pull request, #9049:
URL: https://github.com/apache/inlong/pull/9049
### 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 be repl
64 matches
Mail list logo
