(flink) branch master updated (d301839dfe2 -> f86c0804121)
This is an automated email from the ASF dual-hosted git repository. roman pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from d301839dfe2 [FLINK-35000][build] Updates link to test code convention in pull request template new 875683082a5 [FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in JobIDLoggingITCase new f86c0804121 [hotfix] Log JobID in checkpoint abort message if available The 2 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../flink/runtime/taskexecutor/TaskExecutor.java | 18 ++ .../org/apache/flink/test/misc/JobIDLoggingITCase.java | 2 ++ 2 files changed, 12 insertions(+), 8 deletions(-)
(flink) 02/02: [hotfix] Log JobID in checkpoint abort message if available
This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f86c08041211bbeddf36c9ff0fbe6ae4abaa3b9d
Author: Roman Khachatryan
AuthorDate: Wed Apr 3 10:23:14 2024 +0200
[hotfix] Log JobID in checkpoint abort message if available
---
.../flink/runtime/taskexecutor/TaskExecutor.java | 18 ++
1 file changed, 10 insertions(+), 8 deletions(-)
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
index 99b4ca7d370..f26e9ef7610 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java
@@ -1116,18 +1116,20 @@ public class TaskExecutor extends RpcEndpoint
implements TaskExecutorGateway {
long checkpointId,
long latestCompletedCheckpointId,
long checkpointTimestamp) {
-log.debug(
-"Abort checkpoint {}@{} for {}.",
-checkpointId,
-checkpointTimestamp,
-executionAttemptID);
-
final Task task = taskSlotTable.getTask(executionAttemptID);
if (task != null) {
-task.notifyCheckpointAborted(checkpointId,
latestCompletedCheckpointId);
+try (MdcCloseable ignored =
+
MdcUtils.withContext(MdcUtils.asContextData(task.getJobID( {
+log.debug(
+"Abort checkpoint {}@{} for {}.",
+checkpointId,
+checkpointTimestamp,
+executionAttemptID);
+task.notifyCheckpointAborted(checkpointId,
latestCompletedCheckpointId);
-return CompletableFuture.completedFuture(Acknowledge.get());
+return CompletableFuture.completedFuture(Acknowledge.get());
+}
} else {
final String message =
"TaskManager received an aborted checkpoint for unknown
task "
(flink) 01/02: [FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in JobIDLoggingITCase
This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 875683082a58636b377bbb0a82bac4d273455e6e
Author: Roman Khachatryan
AuthorDate: Wed Apr 3 10:19:34 2024 +0200
[FLINK-34994][tests] Ignore unknown task checkpoint confirmation log in
JobIDLoggingITCase
---
.../src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java| 2 ++
1 file changed, 2 insertions(+)
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java
index fb4e27604fe..0d99a9fce80 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/misc/JobIDLoggingITCase.java
@@ -153,6 +153,8 @@ class JobIDLoggingITCase {
"Received task .*",
"Trigger checkpoint .*",
"Confirm completed checkpoint .*"),
+"TaskManager received a checkpoint confirmation for unknown
task.*",
+"TaskManager received an aborted checkpoint for unknown
task.*",
"Un-registering task.*",
"Successful registration.*",
"Establish JobManager connection.*",
(flink) branch release-1.18 updated: [FLINK-35000][build] Updates link to test code convention in pull request template
This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.18 by this push: new 9150f93b18b [FLINK-35000][build] Updates link to test code convention in pull request template 9150f93b18b is described below commit 9150f93b18b8694646092a6ed24a14e3653f613f Author: Matthias Pohl AuthorDate: Wed Apr 3 14:08:27 2024 +0200 [FLINK-35000][build] Updates link to test code convention in pull request template --- .github/PULL_REQUEST_TEMPLATE.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/PULL_REQUEST_TEMPLATE.md b/.github/PULL_REQUEST_TEMPLATE.md index 8b0cbf71ea8..2427fd4f01f 100644 --- a/.github/PULL_REQUEST_TEMPLATE.md +++ b/.github/PULL_REQUEST_TEMPLATE.md @@ -39,7 +39,7 @@ ## Verifying this change -Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing +Please make sure both new and modified tests in this PR follow [the conventions for tests defined in our code quality guide](https://flink.apache.org/how-to-contribute/code-style-and-quality-common/#7-testing). *(Please pick either of the following options)*
(flink) branch release-1.19 updated: [FLINK-35000][build] Updates link to test code convention in pull request template
This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new eb58599b434 [FLINK-35000][build] Updates link to test code convention in pull request template eb58599b434 is described below commit eb58599b434b6c5fe86f6e487ce88315c98b4ec3 Author: Matthias Pohl AuthorDate: Wed Apr 3 14:08:27 2024 +0200 [FLINK-35000][build] Updates link to test code convention in pull request template --- .github/PULL_REQUEST_TEMPLATE.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/PULL_REQUEST_TEMPLATE.md b/.github/PULL_REQUEST_TEMPLATE.md index 8b0cbf71ea8..2427fd4f01f 100644 --- a/.github/PULL_REQUEST_TEMPLATE.md +++ b/.github/PULL_REQUEST_TEMPLATE.md @@ -39,7 +39,7 @@ ## Verifying this change -Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing +Please make sure both new and modified tests in this PR follow [the conventions for tests defined in our code quality guide](https://flink.apache.org/how-to-contribute/code-style-and-quality-common/#7-testing). *(Please pick either of the following options)*
(flink) branch master updated: [FLINK-35000][build] Updates link to test code convention in pull request template
This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/master by this push: new d301839dfe2 [FLINK-35000][build] Updates link to test code convention in pull request template d301839dfe2 is described below commit d301839dfe2ed9b1313d23f8307bda76868a0c0a Author: Matthias Pohl AuthorDate: Wed Apr 3 14:08:27 2024 +0200 [FLINK-35000][build] Updates link to test code convention in pull request template --- .github/PULL_REQUEST_TEMPLATE.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/PULL_REQUEST_TEMPLATE.md b/.github/PULL_REQUEST_TEMPLATE.md index 8b0cbf71ea8..2427fd4f01f 100644 --- a/.github/PULL_REQUEST_TEMPLATE.md +++ b/.github/PULL_REQUEST_TEMPLATE.md @@ -39,7 +39,7 @@ ## Verifying this change -Please make sure both new and modified tests in this PR follows the conventions defined in our code quality guide: https://flink.apache.org/contributing/code-style-and-quality-common.html#testing +Please make sure both new and modified tests in this PR follow [the conventions for tests defined in our code quality guide](https://flink.apache.org/how-to-contribute/code-style-and-quality-common/#7-testing). *(Please pick either of the following options)*
(flink) branch release-1.18 updated: [FLINK-34955] Upgrade commons-compress to 1.26.0.
This is an automated email from the ASF dual-hosted git repository. mbalassi pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.18 by this push: new 1711ba85744 [FLINK-34955] Upgrade commons-compress to 1.26.0. 1711ba85744 is described below commit 1711ba85744d917ca63d989bf4c120c6aebda9ba Author: Márton Balassi AuthorDate: Wed Apr 3 15:06:53 2024 +0200 [FLINK-34955] Upgrade commons-compress to 1.26.0. Addresses 2 CVE as described at https://mvnrepository.com/artifact/org.apache.commons/commons-compress. - Co-authored-by: slfan1989 <55643692+slfan1...@users.noreply.github.com> --- flink-dist/src/main/resources/META-INF/NOTICE| 4 ++-- flink-end-to-end-tests/flink-sql-client-test/pom.xml | 7 +++ .../src/main/resources/META-INF/NOTICE | 4 ++-- .../flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE| 4 ++-- .../flink-s3-fs-presto/src/main/resources/META-INF/NOTICE| 4 ++-- .../src/main/resources/META-INF/NOTICE | 4 +++- .../flink-sql-avro/src/main/resources/META-INF/NOTICE| 2 +- flink-python/pom.xml | 12 .../flink-table-planner/src/main/resources/META-INF/NOTICE | 2 +- pom.xml | 5 +++-- 10 files changed, 35 insertions(+), 13 deletions(-) diff --git a/flink-dist/src/main/resources/META-INF/NOTICE b/flink-dist/src/main/resources/META-INF/NOTICE index 8eb3dbc5dc7..bb94111ed64 100644 --- a/flink-dist/src/main/resources/META-INF/NOTICE +++ b/flink-dist/src/main/resources/META-INF/NOTICE @@ -11,8 +11,8 @@ This project bundles the following dependencies under the Apache Software Licens - com.ververica:frocksdbjni:6.20.3-ververica-2.0 - commons-cli:commons-cli:1.5.0 - commons-collections:commons-collections:3.2.2 -- commons-io:commons-io:2.11.0 -- org.apache.commons:commons-compress:1.21 +- commons-io:commons-io:2.15.1 +- org.apache.commons:commons-compress:1.26.0 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-math3:3.6.1 - org.apache.commons:commons-text:1.10.0 diff --git a/flink-end-to-end-tests/flink-sql-client-test/pom.xml b/flink-end-to-end-tests/flink-sql-client-test/pom.xml index 5e816c66943..d7c1c1dc567 100644 --- a/flink-end-to-end-tests/flink-sql-client-test/pom.xml +++ b/flink-end-to-end-tests/flink-sql-client-test/pom.xml @@ -69,6 +69,13 @@ under the License. kafka test + + + commons-codec + commons-codec + test + + diff --git a/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE index 0236725e0a4..41d0788e3b7 100644 --- a/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE +++ b/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE @@ -16,9 +16,9 @@ This project bundles the following dependencies under the Apache Software Licens - com.google.j2objc:j2objc-annotations:1.1 - commons-beanutils:commons-beanutils:1.9.4 - commons-collections:commons-collections:3.2.2 -- commons-io:commons-io:2.11.0 +- commons-io:commons-io:2.15.1 - commons-logging:commons-logging:1.1.3 -- org.apache.commons:commons-compress:1.21 +- org.apache.commons:commons-compress:1.26.0 - org.apache.commons:commons-configuration2:2.1.1 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-text:1.10.0 diff --git a/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE index c16ab1adc98..5e66fa4612a 100644 --- a/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE +++ b/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE @@ -21,10 +21,10 @@ This project bundles the following dependencies under the Apache Software Licens - commons-beanutils:commons-beanutils:1.9.4 - commons-codec:commons-codec:1.15 - commons-collections:commons-collections:3.2.2 -- commons-io:commons-io:2.11.0 +- commons-io:commons-io:2.15.1 - commons-logging:commons-logging:1.1.3 - joda-time:joda-time:2.5 -- org.apache.commons:commons-compress:1.21 +- org.apache.commons:commons-compress:1.26.0 - org.apache.commons:commons-configuration2:2.1.1 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-text:1.10.0 diff --git a/flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE index 3356afa2205..eccf85b9a1a 100644 ---
(flink) branch release-1.19 updated: [FLINK-34955] Upgrade commons-compress to 1.26.0.
This is an automated email from the ASF dual-hosted git repository. mbalassi pushed a commit to branch release-1.19 in repository https://gitbox.apache.org/repos/asf/flink.git The following commit(s) were added to refs/heads/release-1.19 by this push: new f17217100cf [FLINK-34955] Upgrade commons-compress to 1.26.0. f17217100cf is described below commit f17217100cf7d28bf6a1b687427c01e30b77e900 Author: Márton Balassi AuthorDate: Wed Apr 3 15:08:32 2024 +0200 [FLINK-34955] Upgrade commons-compress to 1.26.0. Addresses 2 CVE as described at https://mvnrepository.com/artifact/org.apache.commons/commons-compress. - Co-authored-by: slfan1989 <55643692+slfan1...@users.noreply.github.com> --- flink-dist/src/main/resources/META-INF/NOTICE| 4 ++-- flink-end-to-end-tests/flink-sql-client-test/pom.xml | 7 +++ .../src/main/resources/META-INF/NOTICE | 4 ++-- .../flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE| 4 ++-- .../flink-s3-fs-presto/src/main/resources/META-INF/NOTICE| 4 ++-- .../src/main/resources/META-INF/NOTICE | 4 +++- .../flink-sql-avro/src/main/resources/META-INF/NOTICE| 2 +- flink-python/pom.xml | 12 .../flink-table-planner/src/main/resources/META-INF/NOTICE | 2 +- pom.xml | 5 +++-- 10 files changed, 35 insertions(+), 13 deletions(-) diff --git a/flink-dist/src/main/resources/META-INF/NOTICE b/flink-dist/src/main/resources/META-INF/NOTICE index 2eb8a611431..9e249c17f6f 100644 --- a/flink-dist/src/main/resources/META-INF/NOTICE +++ b/flink-dist/src/main/resources/META-INF/NOTICE @@ -11,8 +11,8 @@ This project bundles the following dependencies under the Apache Software Licens - com.ververica:frocksdbjni:6.20.3-ververica-2.0 - commons-cli:commons-cli:1.5.0 - commons-collections:commons-collections:3.2.2 -- commons-io:commons-io:2.11.0 -- org.apache.commons:commons-compress:1.24.0 +- commons-io:commons-io:2.15.1 +- org.apache.commons:commons-compress:1.26.0 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-math3:3.6.1 - org.apache.commons:commons-text:1.10.0 diff --git a/flink-end-to-end-tests/flink-sql-client-test/pom.xml b/flink-end-to-end-tests/flink-sql-client-test/pom.xml index 4ab55e744c0..037c7e6c026 100644 --- a/flink-end-to-end-tests/flink-sql-client-test/pom.xml +++ b/flink-end-to-end-tests/flink-sql-client-test/pom.xml @@ -69,6 +69,13 @@ under the License. kafka test + + + commons-codec + commons-codec + test + + diff --git a/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE index 7163355eb5b..9e5bde2492b 100644 --- a/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE +++ b/flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/META-INF/NOTICE @@ -16,9 +16,9 @@ This project bundles the following dependencies under the Apache Software Licens - com.google.j2objc:j2objc-annotations:1.1 - commons-beanutils:commons-beanutils:1.9.4 - commons-collections:commons-collections:3.2.2 -- commons-io:commons-io:2.11.0 +- commons-io:commons-io:2.15.1 - commons-logging:commons-logging:1.1.3 -- org.apache.commons:commons-compress:1.24.0 +- org.apache.commons:commons-compress:1.26.0 - org.apache.commons:commons-configuration2:2.1.1 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-text:1.10.0 diff --git a/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE index ae30f0d85df..5c9c2a03e15 100644 --- a/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE +++ b/flink-filesystems/flink-s3-fs-hadoop/src/main/resources/META-INF/NOTICE @@ -21,10 +21,10 @@ This project bundles the following dependencies under the Apache Software Licens - commons-beanutils:commons-beanutils:1.9.4 - commons-codec:commons-codec:1.15 - commons-collections:commons-collections:3.2.2 -- commons-io:commons-io:2.11.0 +- commons-io:commons-io:2.15.1 - commons-logging:commons-logging:1.1.3 - joda-time:joda-time:2.5 -- org.apache.commons:commons-compress:1.24.0 +- org.apache.commons:commons-compress:1.26.0 - org.apache.commons:commons-configuration2:2.1.1 - org.apache.commons:commons-lang3:3.12.0 - org.apache.commons:commons-text:1.10.0 diff --git a/flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE b/flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE index d84ee2c57d7..75a956d1707 100644 ---
(flink) branch master updated: [FLINK-28693][table] Janino compile failed because of the generated code refers a class in table-planner
This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 0acf92f1c8a [FLINK-28693][table] Janino compile failed because of the
generated code refers a class in table-planner
0acf92f1c8a is described below
commit 0acf92f1c8a90dcb3eb2c1038c1cda3344b7b988
Author: Xuyang
AuthorDate: Wed Apr 3 18:24:14 2024 +0800
[FLINK-28693][table] Janino compile failed because of the generated code
refers a class in table-planner
---
.../CompileAndExecuteRemotePlanITCase.java | 2 +-
.../sql/{codegen => }/CreateTableAsITCase.java | 2 +-
.../table/sql/{codegen => }/HdfsITCaseBase.java| 2 +-
.../sql/{codegen => }/PlannerScalaFreeITCase.java | 11 ++-
.../table/sql/{codegen => }/SqlITCaseBase.java | 2 +-
.../sql/{codegen => }/UsingRemoteJarITCase.java| 2 +-
.../src/test/resources/watermark_push_down_e2e.sql | 44 +
.../flink-sql-client-test/pom.xml | 7 ++
.../TestScanTableSourceWithWatermarkPushDown.java | 66 +
...canTableSourceWithWatermarkPushDownFactory.java | 52 ++
.../flink/table/toolbox/TestSourceFunction.java| 110 +
.../org.apache.flink.table.factories.Factory | 16 +++
.../codegen/WatermarkGeneratorCodeGenerator.scala | 10 +-
...neratorCodeGeneratorFunctionContextWrapper.java | 44 +
14 files changed, 355 insertions(+), 15 deletions(-)
diff --git
a/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CompileAndExecuteRemotePlanITCase.java
b/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/CompileAndExecuteRemotePlanITCase.java
similarity index 98%
rename from
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CompileAndExecuteRemotePlanITCase.java
rename to
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/CompileAndExecuteRemotePlanITCase.java
index b74c70794ab..439770cce24 100644
---
a/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CompileAndExecuteRemotePlanITCase.java
+++
b/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/CompileAndExecuteRemotePlanITCase.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.sql.codegen;
+package org.apache.flink.table.sql;
import org.apache.hadoop.fs.LocatedFileStatus;
import org.apache.hadoop.fs.RemoteIterator;
diff --git
a/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CreateTableAsITCase.java
b/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/CreateTableAsITCase.java
similarity index 98%
rename from
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CreateTableAsITCase.java
rename to
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/CreateTableAsITCase.java
index fb727b73ee2..35a8ff605d1 100644
---
a/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/CreateTableAsITCase.java
+++
b/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/CreateTableAsITCase.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.sql.codegen;
+package org.apache.flink.table.sql;
import
org.apache.flink.formats.json.debezium.DebeziumJsonDeserializationSchema;
import org.apache.flink.table.api.DataTypes;
diff --git
a/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/HdfsITCaseBase.java
b/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/HdfsITCaseBase.java
similarity index 99%
rename from
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/HdfsITCaseBase.java
rename to
flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/HdfsITCaseBase.java
index a3f83ddd95a..4aa7601c03c 100644
---
a/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/codegen/HdfsITCaseBase.java
+++
b/flink-end-to-end-tests/flink-end-to-end-tests-sql/src/test/java/org/apache/flink/table/sql/HdfsITCaseBase.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.sql.codegen;
+package org.apache.flink.table.sql;
import org.apache.flink.test.resources.ResourceTestUtils;
import org.apache.flink.test.util.SQLJobSubmission;
diff --git
Re: [I] Error on Postgres-CDC using incremental snapshot with UUID column as PK [flink-cdc]
loserwang1024 commented on issue #3108: URL: https://github.com/apache/flink-cdc/issues/3108#issuecomment-2033865296 @olivier-derom It seems a bug, could you please create a [jira ](https://issues.apache.org/jira/browse/FLINK-34952)and fix it? If you don't have time, I'd like to help you todo 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 comment. To unsubscribe, e-mail: commits-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
