junzhong qin created FLINK-34526: ------------------------------------ Summary: Without shuffling data, when a Task Manager is killed, restarting the Flink job takes a considerable amount of time Key: FLINK-34526 URL: https://issues.apache.org/jira/browse/FLINK-34526 Project: Flink Issue Type: Sub-task Reporter: junzhong qin Attachments: image-2024-02-27-15-50-25-071.png, image-2024-02-27-15-50-39-337.png
In our test case, the pipeline is: !image-2024-02-27-15-50-25-071.png! parallelism = 100 and taskmanager.numberOfTaskSlots = 2 When the worker was killed at 2024-02-27 15:10:13,691 {code:java} 2024-02-27 15:10:13,691 INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Worker container_e2472_1706081484717_60538_01_000050 is terminated. Diagnostics: Container container_e2472_1706081484717_60538_01_000050 marked as failed. Exit code:137. Diagnostics:[2024-02-27 15:10:12.720]Container killed on request. Exit code is 137[2024-02-27 15:10:12.763]Container exited with a non-zero exit code 137. [2024-02-27 15:10:12.839]Killed by external signal {code} It took about 20 seconds to restart the job. {code:java} 2024-02-27 15:10:30,749 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: datagen_source[1] -> Sink: print_sink[2] (70/100) (2a1d06e6610bc499475fa6e647f8cac9_d3f21cabc6fe0fdf76c8be915bdb22a2_69_0) switched from RUNNING to FAILED on container_e2472_1706081484717_60538_01_000050 @ ip-10-169-18-98.idata-server.shopee.io (dataPort=38597).org.apache.flink.runtime.jobmaster.JobMasterException: TaskManager with id container_e2472_1706081484717_60538_01_000050(ip-10-169-18-98.idata-server.shopee.io:5454) is no longer reachable. at org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyTargetUnreachable(JobMaster.java:1515) ~[flink-dist-shopee-1.17-SNAPSHOT.jar:shopee-1.17-SNAPSHOT] at org.apache.flink.runtime.heartbeat.DefaultHeartbeatMonitor.reportHeartbeatRpcFailure(DefaultHeartbeatMonitor.java:126) ~[flink-dist-shopee-1.17-SNAPSHOT.jar:shopee-1.17-SNAPSHOT] at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl.runIfHeartbeatMonitorExists(HeartbeatManagerImpl.java:275) ~[flink-dist-shopee-1.17-SNAPSHOT.jar:shopee-1.17-SNAPSHOT] at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl.reportHeartbeatTargetUnreachable(HeartbeatManagerImpl.java:267) ~[flink-dist-shopee-1.17-SNAPSHOT.jar:shopee-1.17-SNAPSHOT] at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl.handleHeartbeatRpcFailure(HeartbeatManagerImpl.java:262) ~[flink-dist-shopee-1.17-SNAPSHOT.jar:shopee-1.17-SNAPSHOT] at org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl.lambda$handleHeartbeatRpc$0(HeartbeatManagerImpl.java:248) ~[flink-dist-shopee-1.17-SNAPSHOT.jar:shopee-1.17-SNAPSHOT] ........ // Deploy and run task 2024-02-27 15:10:32,426 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: datagen_source[1] -> Sink: print_sink[2] (70/100) (2a1d06e6610bc499475fa6e647f8cac9_d3f21cabc6fe0fdf76c8be915bdb22a2_69_1) switched from DEPLOYING to INITIALIZING.2024-02-27 15:10:32,427 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: datagen_source[1] -> Sink: print_sink[2] (69/100) (2a1d06e6610bc499475fa6e647f8cac9_d3f21cabc6fe0fdf76c8be915bdb22a2_68_1) switched from DEPLOYING to INITIALIZING.2024-02-27 15:10:33,347 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: datagen_source[1] -> Sink: print_sink[2] (70/100) (2a1d06e6610bc499475fa6e647f8cac9_d3f21cabc6fe0fdf76c8be915bdb22a2_69_1) switched from INITIALIZING to RUNNING.2024-02-27 15:10:33,421 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: datagen_source[1] -> Sink: print_sink[2] (69/100) (2a1d06e6610bc499475fa6e647f8cac9_d3f21cabc6fe0fdf76c8be915bdb22a2_68_1) switched from INITIALIZING to RUNNING. {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)