[Improve][e2e][Flink] Execute extra commands on task manager container (

#3224)
apache · Oct 30, 2022 · 0e85e1c · 0e85e1c
1 parent b485187
commit 0e85e1c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java b/...test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java
@@ -114,6 +114,7 @@ protected List<String> getExtraStartShellCommands() {
 
     public void executeExtraCommands(ContainerExtendedFactory extendedFactory) throws IOException, InterruptedException {
         extendedFactory.extend(jobManager);
+        extendedFactory.extend(taskManager);
     }
 
     @Override