[incubator-seatunnel] branch dev updated: [Improve][e2e][Flink] Execute extra commands on task manager container (#3224)

[gaojun2048]

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 <tyrantluci...@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