This is an automated email from the ASF dual-hosted git repository.

kunni pushed a commit to branch FLINK-38730-copy
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git

commit 5e0acee36f99f2c7a9016e56d37505d0a8160474
Author: lvyanquan <[email protected]>
AuthorDate: Tue Dec 9 15:17:59 2025 +0800

    Address comment.
---
 .../apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java | 3 ++-
 flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/pom.xml                 | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java
 
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java
index 1534ae4e8..bf0c9f4cc 100644
--- 
a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java
+++ 
b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java
@@ -137,9 +137,10 @@ public abstract class PipelineTestEnvironment extends 
TestLogger {
                     "parallelism.default: 4",
                     "execution.checkpointing.interval: 300",
                     "state.backend.type: hashmap",
-                    "env.java.opts.all: -Doracle.jdbc.timezoneAsRegion=false",
+                    "env.java.opts.all: 
--add-exports=java.base/sun.net.util=ALL-UNNAMED 
--add-exports=java.rmi/sun.rmi.registry=ALL-UNNAMED 
--add-exports=jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED 
--add-exports=jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED 
--add-exports=jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED 
--add-exports=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED 
--add-exports=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED 
--add-exports=java.security.jg [...]
                     "execution.checkpointing.savepoint-dir: file:///opt/flink",
                     "restart-strategy.type: off",
+                    "pekko.ask.timeout: 60s",
                     // Set off-heap memory explicitly to avoid 
"java.lang.OutOfMemoryError: Direct
                     // buffer memory" error.
                     "taskmanager.memory.task.off-heap.size: 128mb",
diff --git a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/pom.xml 
b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/pom.xml
index 4c75e53fe..c8dd5df6e 100644
--- a/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/pom.xml
+++ b/flink-cdc-e2e-tests/flink-cdc-source-e2e-tests/pom.xml
@@ -212,7 +212,7 @@ limitations under the License.
                 <executions>
                     <execution>
                         <id>copy-jars</id>
-                        <phase>test</phase>
+                        <phase>package</phase>
                         <goals>
                             <goal>copy</goal>
                         </goals>

Reply via email to