gong commented on code in PR #7062:
URL: https://github.com/apache/inlong/pull/7062#discussion_r1057554402
##
inlong-sort/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java:
##
@@ -507,8 +512,35 @@ private void handleDirtyD
featzhang opened a new pull request, #7077:
URL: https://github.com/apache/inlong/pull/7077
### Prepare a Pull Request
*[INLONG-7072][Manager][Sort] Resource adaptive adjustment for Hudi*
- Fixes #7072
### Motivation
Hudi flink jobs often have unreasonable resourc
kuansix opened a new pull request, #7078:
URL: https://github.com/apache/inlong/pull/7078
### Prepare a Pull Request
- [INLONG-7075][Sort] Add table level metric for PostgreSQL
- Fixes #7075
### Motivation
*Explain here the context, and why you're making that change. What
healchow commented on code in PR #7078:
URL: https://github.com/apache/inlong/pull/7078#discussion_r1058012354
##
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java:
##
@@ -532,6 +515,20 @@ protected void attemp
chyueyi opened a new pull request, #7079:
URL: https://github.com/apache/inlong/pull/7079
## Prepare a Pull Request
- [[INLONG-7076] [sort-connector-jdbc] Add multi table sink for
MySQL](https://github.com/apache/inlong/issues/7076)
- Fixes #XYZ
### Motivation
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 699af0d53 [INLONG-7070][Manager][DataProxy] Fix mq configuration
dispatching problem (#7071)
add 6a35533c1 [INLON
EMsnap merged PR #7074:
URL: https://github.com/apache/inlong/pull/7074
--
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
kuansix commented on code in PR #7078:
URL: https://github.com/apache/inlong/pull/7078#discussion_r1058024563
##
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java:
##
@@ -532,6 +515,20 @@ protected void attempt
fuweng11 opened a new pull request, #7081:
URL: https://github.com/apache/inlong/pull/7081
### Prepare a Pull Request
- Fixes #7080
### Motivation
Use the `StringUtils.isNotBlank` uniformly instead of
`StringUtils.isNoneBlank`.
### Modifications
Use the `Strin
gong commented on code in PR #7079:
URL: https://github.com/apache/inlong/pull/7079#discussion_r1058074563
##
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDialects.java:
##
@@ -18,7 +18,8 @@
package org.apache.inlong.sort.jdbc.table;
i
gong commented on code in PR #7079:
URL: https://github.com/apache/inlong/pull/7079#discussion_r1058077632
##
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/converter/AbstractJdbcRowConverter.java:
##
@@ -25,11 +25,7 @@
import org.apache.flink.table.
gong commented on PR #7078:
URL: https://github.com/apache/inlong/pull/7078#issuecomment-1366395406
1、lost dirty data metric restore
```java
public void open(int taskNumber, int numTasks) throws IOException {
this.runtimeContext = getRuntimeContext();
MetricOption
gong merged PR #7081:
URL: https://github.com/apache/inlong/pull/7081
--
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.apache.
This is an automated email from the ASF dual-hosted git repository.
pacinogong 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 7c9044a54 [INLONG-7080][Manager] Use the Str
gong commented on code in PR #7059:
URL: https://github.com/apache/inlong/pull/7059#discussion_r1058092502
##
inlong-sort/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/common/KuduUtils.java:
##
@@ -0,0 +1,142 @@
+/*
+ * Licensed to the Apache Software Foundation
gong commented on code in PR #7059:
URL: https://github.com/apache/inlong/pull/7059#discussion_r1058093963
##
inlong-sort/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/sink/AbstractKuduSinkFunction.java:
##
@@ -0,0 +1,206 @@
+/*
+ * Licensed to the Apache Softwa
gong commented on code in PR #7059:
URL: https://github.com/apache/inlong/pull/7059#discussion_r1058095936
##
inlong-sort/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/common/KuduOptions.java:
##
@@ -0,0 +1,125 @@
+/*
+ * Licensed to the Apache Software Foundati
chyueyi commented on PR #7079:
URL: https://github.com/apache/inlong/pull/7079#issuecomment-1366411665
@gong OK, I've modified it.
--
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 com
gong commented on code in PR #7059:
URL: https://github.com/apache/inlong/pull/7059#discussion_r1058096505
##
inlong-sort/sort-connectors/kudu/src/main/java/org/apache/inlong/sort/kudu/table/KuduDynamicTableSink.java:
##
@@ -0,0 +1,258 @@
+/*
+ * Licensed to the Apache Software
gong commented on code in PR #7059:
URL: https://github.com/apache/inlong/pull/7059#discussion_r1058097244
##
inlong-sort/sort-connectors/kudu/pom.xml:
##
@@ -0,0 +1,93 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
gong commented on code in PR #7059:
URL: https://github.com/apache/inlong/pull/7059#discussion_r1058097548
##
inlong-sort/sort-connectors/kudu/pom.xml:
##
@@ -0,0 +1,93 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
gong commented on PR #7059:
URL: https://github.com/apache/inlong/pull/7059#issuecomment-1366413893
add fileSet for kudu connector in
inlong-distribution/src/main/assemblies/sort-connectors.xml
--
This is an automated message from the Apache Git Service.
To respond to the message, please
gong commented on PR #7079:
URL: https://github.com/apache/inlong/pull/7079#issuecomment-1366414528
@kuansix please help to review it
--
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
bluewang opened a new pull request, #7084:
URL: https://github.com/apache/inlong/pull/7084
### 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 rep
liaorui opened a new pull request, #7085:
URL: https://github.com/apache/inlong/pull/7085
### 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 replaced
25 matches
Mail list logo
