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

Savepoint for job error

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 1.9.3
    • Fix Version/s: 1.10.1
    • Component/s: Command Line Client
    • Labels:
      None

      Description

      Triggering savepoint for job ea4ff34da1a64412e515518fdcc0bdc1.
      Waiting for response...

      ------------------------------------------------------------
      The program finished with the following exception:

      org.apache.flink.util.FlinkException: Triggering a savepoint for the job ea4ff34da1a64412e515518fdcc0bdc1 failed.
      at org.apache.flink.client.cli.CliFrontend.triggerSavepoint(CliFrontend.java:708)
      at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$9(CliFrontend.java:687)
      at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:943)
      at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:684)
      at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1023)
      at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1081)
      at java.security.AccessController.doPrivileged(Native Method)
      at javax.security.auth.Subject.doAs(Subject.java:422)
      at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1911)
      at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
      at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1081)
      Caused by: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Number of retries has been exhausted.
      at org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:273)
      at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
      at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
      at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
      at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561)
      at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929)
      at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      at java.lang.Thread.run(Thread.java:748)
      Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.util.RestClientException: Response was neither of the expected type([simple type, class org.apache.flink.runtime.rest.handler.async.TriggerResponse]) nor an error.
      at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
      at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
      at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
      at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953)
      at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
      ... 4 more
      Caused by: org.apache.flink.runtime.rest.util.RestClientException: Response was neither of the expected type([simple type, class org.apache.flink.runtime.rest.handler.async.TriggerResponse]) nor an error.
      at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:398)
      at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:373)
      at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:952)
      ... 5 more
      Caused by: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.ValueInstantiationException: Cannot construct instance of `org.apache.flink.runtime.rest.handler.async.TriggerResponse`, problem: `java.lang.NullPointerException`
      at [Source: UNKNOWN; line: -1, column: -1]
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.ValueInstantiationException.from(ValueInstantiationException.java:47)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.instantiationException(DeserializationContext.java:1732)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdValueInstantiator.wrapAsJsonMappingException(StdValueInstantiator.java:491)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdValueInstantiator.rewrapCtorProblem(StdValueInstantiator.java:514)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdValueInstantiator.createFromObjectWith(StdValueInstantiator.java:285)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.ValueInstantiator.createFromObjectWith(ValueInstantiator.java:229)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.impl.PropertyBasedCreator.build(PropertyBasedCreator.java:198)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased(BeanDeserializer.java:488)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault(BeanDeserializerBase.java:1287)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:326)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:159)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readValue(ObjectMapper.java:4173)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:2536)
      at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:381)
      ... 7 more
      Caused by: java.lang.NullPointerException
      at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:58)
      at org.apache.flink.runtime.rest.handler.async.TriggerResponse.<init>(TriggerResponse.java:40)
      at sun.reflect.GeneratedConstructorAccessor4.newInstance(Unknown Source)
      at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
      at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.introspect.AnnotatedConstructor.call(AnnotatedConstructor.java:124)
      at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdValueInstantiator.createFromObjectWith(StdValueInstantiator.java:283)
      ... 16 more

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              Kayo2020 Kayo
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: