(DEPRECATED) Apache Flink Mailing List archive.

[jira] [Created] (FLINK-21644) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed

Classic

List

Threaded

1 message

Shang Yuanchun (Jira)

[jira] [Created] (FLINK-21644) Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed

Guowei Ma created FLINK-21644:
---------------------------------

Summary: 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

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)