You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ga...@apache.org on 2022/10/30 07:56:16 UTC
[incubator-seatunnel] branch dev updated: [Improve][e2e][Flink] Execute extra commands on task manager container (#3224)
This is an automated email from the ASF dual-hosted git repository.
gaojun2048 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 0e85e1c57 [Improve][e2e][Flink] Execute extra commands on task manager container (#3224)
0e85e1c57 is described below
commit 0e85e1c57d1b7645a90661bbf2ebda4fe0a9c83c
Author: TyrantLucifer <Ty...@gmail.com>
AuthorDate: Sun Oct 30 15:56:12 2022 +0800
[Improve][e2e][Flink] Execute extra commands on task manager container (#3224)
---
.../seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java
index 8bc2d5eb4..4a4dbfa9e 100644
--- a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java
+++ b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java
@@ -114,6 +114,7 @@ public abstract class AbstractTestFlinkContainer extends AbstractTestContainer {
public void executeExtraCommands(ContainerExtendedFactory extendedFactory) throws IOException, InterruptedException {
extendedFactory.extend(jobManager);
+ extendedFactory.extend(taskManager);
}
@Override