flink checkpoint 恢复_Flink 从Checkpoint中恢复作业

时间：2025-04-09 07:12:51
2020-12-26 20:48:12,967 WARN [] - Source: MySourceFunction -> MyFlatMapFunction (1/1) (be8abffb0f6815889929dc9b605b7ae5) switched from RUNNING to : custom error flag, restart application at $1.flatMap(:39) ~[blob_p-353721c11ae1acd403dc8be3b663e9a60854d5c3-b6237955a73f418e6d7b272281b64594:?] at $1.flatMap(:34) ~[blob_p-353721c11ae1acd403dc8be3b663e9a60854d5c3-b6237955a73f418e6d7b272281b64594:?] at (:50) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at $(:717) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at $(:692) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at $(:672) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at (:52) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at (:30) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at $(:104) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at .source.SocketTextStreamFunction.run(:111) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at .run(:100) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at .run(:63) ~[flink-dist_2.12-1.11.2.jar:1.11.2] at $LegacySourceFunctionThread.run(:213) ~[flink-dist_2.12-1.11.2.jar:1.11.2]2020-12-26 20:48:12,978 INFO [] - Attempting to cancel task MySumFunction -> Sink: MyPrintFunction (1/1) (d464321ae464046684fd28d37bdcc3d7).2020-12-26 20:48:12,978 INFO [] - MySumFunction -> Sink: MyPrintFunction (1/1) (d464321ae464046684fd28d37bdcc3d7) switched from RUNNING to CANCELING....2020-12-26 20:48:12,979 INFO [] - MySumFunction -> Sink: MyPrintFunction (1/1) (d464321ae464046684fd28d37bdcc3d7) switched from CANCELING to CANCELED.

相关文章