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

stop-with-savepoint fails and times out with simple reproducible example

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Invalid
    • 1.17.0
    • None
    • API / DataStream
    • None

    Description

      I've put together a simple demo app that reproduces the issue with instructions on how to reproduce:

      https://github.com/kurtostfeld/flink-stop-issue

       

      The issue is that with a very simple Flink DataStream API application, the `stop-with-savepoint` fails and times out like this:

       

      ./bin/flink stop --type native --savepointPath ../savepoints d69a952625497cca0665dfdcdb9f4718
      
      Suspending job "d69a952625497cca0665dfdcdb9f4718" with a NATIVE savepoint.
      
      ------------------------------------------------------------
       The program finished with the following exception:
      
      org.apache.flink.util.FlinkException: Could not stop with a savepoint job "d69a952625497cca0665dfdcdb9f4718".
          at org.apache.flink.client.cli.CliFrontend.lambda$stop$4(CliFrontend.java:595)
          at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:1041)
          at org.apache.flink.client.cli.CliFrontend.stop(CliFrontend.java:578)
          at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1110)
          at org.apache.flink.client.cli.CliFrontend.lambda$mainInternal$9(CliFrontend.java:1189)
          at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
          at org.apache.flink.client.cli.CliFrontend.mainInternal(CliFrontend.java:1189)
          at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1157)
      Caused by: java.util.concurrent.TimeoutException
          at java.base/java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1886)
          at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2021)
          at org.apache.flink.client.cli.CliFrontend.lambda$stop$4(CliFrontend.java:591)
          ... 7 more 

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            kurto Kurt Ostfeld
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: