Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21644

Resuming Savepoint (rocks, scale up, heap timers) end-to-end test failed

    XMLWordPrintableJSON

    Details

      Description

      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.

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

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              maguowei Guowei Ma
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: