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

LeaderChangeStateCleanupTest times out

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Minor
    • Resolution: Fixed
    • 1.1.0
    • 1.1.0
    • Tests

    Description

      cluster.waitForTaskManagersToBeRegistered(); needs to be replaced by cluster.waitForTaskManagersToBeRegistered(timeout);

      testStateCleanupAfterListenerNotification(org.apache.flink.runtime.leaderelection.LeaderChangeStateCleanupTest)  Time elapsed: 10.106 sec  <<< ERROR!
      java.util.concurrent.TimeoutException: Futures timed out after [10000 milliseconds]
      	at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
      	at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:153)
      	at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86)
      	at scala.concurrent.Await$$anonfun$ready$1.apply(package.scala:86)
      	at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
      	at scala.concurrent.Await$.ready(package.scala:86)
      	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.waitForTaskManagersToBeRegistered(FlinkMiniCluster.scala:455)
      	at org.apache.flink.runtime.minicluster.FlinkMiniCluster.waitForTaskManagersToBeRegistered(FlinkMiniCluster.scala:439)
      	at org.apache.flink.runtime.leaderelection.LeaderChangeStateCleanupTest.testStateCleanupAfterListenerNotification(LeaderChangeStateCleanupTest.java:181)
      

      Attachments

        Issue Links

          Activity

            People

              mxm Maximilian Michels
              mxm Maximilian Michels
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: