This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new e826d2469 [Bug][Flink-connector-v2-e2e] Replace the flink docker name
(#2291) (#2297)
e826d2469 is described below
commit e826d24699b3ab291d04ad4f265b3851e70c4d04
Author: TyrantLucifer <[email protected]>
AuthorDate: Mon Aug 1 10:47:58 2022 +0800
[Bug][Flink-connector-v2-e2e] Replace the flink docker name (#2291) (#2297)
---
.../src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
b/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
index 0ffa31634..c6f7b26c9 100644
---
a/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
+++
b/seatunnel-e2e/seatunnel-flink-connector-v2-e2e/src/test/java/org/apache/seatunnel/e2e/flink/FlinkContainer.java
@@ -47,7 +47,7 @@ public abstract class FlinkContainer {
private static final Logger LOG =
LoggerFactory.getLogger(FlinkContainer.class);
- private static final String FLINK_DOCKER_IMAGE = "flink:1.13.6-scala_2.11";
+ private static final String FLINK_DOCKER_IMAGE =
"tyrantlucifer/flink:1.13.6-scala_2.11_hadoop27";
protected static final Network NETWORK = Network.newNetwork();
protected GenericContainer<?> jobManager;