aloyszhang commented on code in PR #10428:
URL: https://github.com/apache/inlong/pull/10428#discussion_r1642097093
##
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/cache/AbstractCache.java:
##
@@ -96,38 +95,47 @@ public Cache getCache() {
public List getD
aloyszhang commented on code in PR #10428:
URL: https://github.com/apache/inlong/pull/10428#discussion_r1642099402
##
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/sink/JdbcSink.java:
##
@@ -153,6 +174,46 @@ protected void createDataSource() {
dataSou
aloyszhang commented on code in PR #10428:
URL: https://github.com/apache/inlong/pull/10428#discussion_r1642099799
##
inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/sink/JdbcSink.java:
##
@@ -153,6 +174,46 @@ protected void createDataSource() {
dataSou
aloyszhang commented on code in PR #10404:
URL: https://github.com/apache/inlong/pull/10404#discussion_r1642101713
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/pom.xml:
##
@@ -169,6 +169,10 @@
com.zaxxer
aloyszhang commented on code in PR #10404:
URL: https://github.com/apache/inlong/pull/10404#discussion_r1642102215
##
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/MySqlExtractNode.java:
##
@@ -311,6 +311,9 @@ public String getMetadataKey(Met
EMsnap commented on code in PR #10404:
URL: https://github.com/apache/inlong/pull/10404#discussion_r1642105460
##
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/pom.xml:
##
@@ -169,6 +169,10 @@
com.zaxxer
EMsnap commented on code in PR #10404:
URL: https://github.com/apache/inlong/pull/10404#discussion_r1642108902
##
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/MySqlExtractNode.java:
##
@@ -311,6 +311,9 @@ public String getMetadataKey(MetaFie
aloyszhang commented on code in PR #10404:
URL: https://github.com/apache/inlong/pull/10404#discussion_r1642121176
##
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/MySqlExtractNode.java:
##
@@ -311,6 +311,9 @@ public String getMetadataKey(Met
EMsnap merged PR #10404:
URL: https://github.com/apache/inlong/pull/10404
--
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.apa
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 89699deee5 [INLONG-10425][Manager] Fix the problem of the kafka sink
defines duplicate attributes (#10426)
add 0a
dockerzhang merged PR #10429:
URL: https://github.com/apache/inlong/pull/10429
--
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
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 0a106ec6c7 [INLONG-10401][Sort] Add audit time metadata for MySQL
connector and relocate debezium dependencies (
12 matches
Mail list logo
