You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Guowei Ma (Jira)" <ji...@apache.org> on 2021/03/07 09:16:00 UTC

[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)