[
https://issues.apache.org/jira/browse/FLINK-21644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17325133#comment-17325133
]
Dawid Wysakowicz commented on FLINK-21644:
------------------------------------------
It is most probably caused by high load on the machines. I've checked the logs
and the job seems to be taking the savepoint just fine but the client times out
right before the savepoint finishes. Given that it did not occur for a while
and that Flink 1.11 reaches end of support I am closing this issue for the time
being.
> Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed
> ------------------------------------------------------------------------
>
> Key: FLINK-21644
> URL: https://issues.apache.org/jira/browse/FLINK-21644
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.11.3
> Reporter: Guowei Ma
> Priority: Major
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=14213&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=2b7514ee-e706-5046-657b-3430666e7bd9
> Due to the some operator exit slowly the test fail.
> We can find that the "EventSource -> Timestamps/Watermarks" exit very quickly.
> But the "ArtificalKeyedStateMapper_Kryo_and_Custom_Stateful" spend another
> 34s to exits.
> {code:java}
> 2021-03-05 21:41:15,327 INFO org.apache.flink.runtime.taskmanager.Task
> [] - Source: EventSource -> Timestamps/Watermarks (2/2)
> (87b0121ed823482e9f5718e99793ee5c) switched from RUNNING to FINISHED.
> 2021-03-05 21:41:15,327 INFO org.apache.flink.runtime.taskmanager.Task
> [] - Freeing task resources for Source: EventSource ->
> Timestamps/Watermarks (2/2) (87b0121ed823482e9f5718e99793ee5c).
> 2021-03-05 21:41:15,332 INFO org.apache.flink.runtime.taskmanager.Task
> [] - Source: EventSource -> Timestamps/Watermarks (1/2)
> (4ede785fe0f1c4c798030ac748da0a95) switched from RUNNING to FINISHED.
> 2021-03-05 21:41:15,332 INFO org.apache.flink.runtime.taskmanager.Task
> [] - Freeing task resources for Source: EventSource ->
> Timestamps/Watermarks (1/2) (4ede785fe0f1c4c798030ac748da0a95).
> 2021-03-05 21:41:15,336 INFO
> org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
> Un-registering task and sending final execution state FINISHED to JobManager
> for task Source: EventSource -> Timestamps/Watermarks (2/2)
> 87b0121ed823482e9f5718e99793ee5c.
> 2021-03-05 21:41:15,338 INFO
> org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
> Un-registering task and sending final execution state FINISHED to JobManager
> for task Source: EventSource -> Timestamps/Watermarks (1/2)
> 4ede785fe0f1c4c798030ac748da0a95.
> 2021-03-05 21:41:16,294 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:17,298 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:18,301 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:19,304 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:20,307 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:21,310 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:22,313 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:23,315 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:24,318 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:25,321 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:26,324 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:27,326 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:28,329 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:29,332 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:30,335 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:31,337 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:32,340 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:33,343 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:34,345 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:35,348 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:36,351 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:37,353 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:38,356 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:39,359 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:40,362 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:41,365 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:42,368 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:43,371 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:44,373 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:45,376 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:46,379 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:47,382 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:48,385 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:49,388 INFO org.apache.flink.metrics.slf4j.Slf4jReporter
> [] -
> 2021-03-05 21:41:49,601 INFO
> org.apache.flink.contrib.streaming.state.RocksDBKeyedStateBackend [] - Closed
> RocksDB State Backend. Cleaning up RocksDB working directory
> /tmp/flink-io-83d8d11e-f3a4-433e-81f3-39075eca8c3d/job_7445670e103edd0eb216e93dd7ab9255_op_StreamMap_52
> 71c210329e73bd743f3227edfb3b71__1_2__uuid_3512e21a-4158-4d7e-bbd8-d0909db46626.
> 2021-03-05 21:41:49,607 INFO org.apache.flink.runtime.taskmanager.Task
> [] - ArtificalKeyedStateMapper_Kryo_and_Custom_Stateful (1/2)
> (418bee0708b657e5ae1d876d6fb7320a) switched from RUNNING to FINISHED.
> 2021-03-05 21:41:49,608 INFO org.apache.flink.runtime.taskmanager.Task
> [] - Freeing task resources for
> ArtificalKeyedStateMapper_Kryo_and_Custom_Stateful (1/2)
> (418bee0708b657e5ae1d876d6fb7320a).
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
