fork download 
  1. java.util.concurrent.ExecutionException: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Job could not be found.
  2. 	at org.apache.flink.runtime.rest.handler.job.JobCancellationHandler.lambda$handleRequest$0(JobCancellationHandler.java:128)
  3. 	at java.base/java.util.concurrent.CompletableFuture.uniHandle(Unknown Source)
  4. 	at java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(Unknown Source)
  5. 	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
  6. 	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source)
  7. 	at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:261)
  8. 	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source)
  9. 	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source)
  10. 	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
  11. 	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source)
  12. 	at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1275)
  13. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
  14. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
  15. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
  16. 	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source)
  17. 	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source)
  18. 	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
  19. 	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source)
  20. 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
  21. 	at akka.dispatch.OnComplete.internal(Future.scala:299)
  22. 	at akka.dispatch.OnComplete.internal(Future.scala:297)
  23. 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
  24. 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
  25. 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
  26. 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
  27. 	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
  28. 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
  29. 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
  30. 	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
  31. 	at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
  32. 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
  33. 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
  34. 	at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
  35. 	at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
  36. 	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
  37. 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
  38. 	at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
  39. 	at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
  40. 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
  41. 	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
  42. 	at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
  43. 	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
  44. 	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
  45. 	at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
  46. 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
  47. 	at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
  48. 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
  49. 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)
  50. Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (0000000008f7fe760000000000000001)
  51. 	at org.apache.flink.runtime.dispatcher.Dispatcher.cancelJob(Dispatcher.java:749)
  52. 	at jdk.internal.reflect.GeneratedMethodAccessor250.invoke(Unknown Source)
  53. 	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
  54. 	at java.base/java.lang.reflect.Method.invoke(Unknown Source)
  55. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
  56. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
  57. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
  58. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
  59. 	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
  60. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
  61. 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
  62. 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
  63. 	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
  64. 	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
  65. 	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
  66. 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
  67. 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
  68. 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
  69. 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
  70. 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
  71. 	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
  72. 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
  73. 	at akka.actor.ActorCell.invoke(ActorCell.scala:548)
  74. 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
  75. 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
  76. 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
  77. 	... 5 more
  78. ]
  79. 	at java.base/java.util.concurrent.CompletableFuture.reportGet(Unknown Source)
  80. 	at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source)
  81. 	at org.apache.flink.kubernetes.operator.service.AbstractFlinkService.cancelSessionJob(AbstractFlinkService.java:405)
  82. 	at org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler.cancelJob(SessionJobReconciler.java:93)
  83. 	at org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler.cleanupInternal(SessionJobReconciler.java:110)
  84. 	at org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler.cleanup(AbstractFlinkResourceReconciler.java:256)
  85. 	at org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.cleanup(FlinkSessionJobController.java:145)
  86. 	at org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController.cleanup(FlinkSessionJobController.java:53)
  87. 	at io.javaoperatorsdk.operator.processing.Controller$2.execute(Controller.java:184)
  88. 	at io.javaoperatorsdk.operator.processing.Controller$2.execute(Controller.java:147)
  89. 	at org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics.timeControllerExecution(OperatorJosdkMetrics.java:80)
  90. 	at io.javaoperatorsdk.operator.processing.Controller.cleanup(Controller.java:146)
  91. 	at io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleCleanup(ReconciliationDispatcher.java:290)
  92. 	at io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleDispatch(ReconciliationDispatcher.java:87)
  93. 	at io.javaoperatorsdk.operator.processing.event.ReconciliationDispatcher.handleExecution(ReconciliationDispatcher.java:62)
  94. 	at io.javaoperatorsdk.operator.processing.event.EventProcessor$ReconcilerExecutor.run(EventProcessor.java:414)
  95. 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
  96. 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
  97. 	at java.base/java.lang.Thread.run(Unknown Source)
  98. Caused by: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Job could not be found.
  99. 	at org.apache.flink.runtime.rest.handler.job.JobCancellationHandler.lambda$handleRequest$0(JobCancellationHandler.java:128)
  100. 	at java.base/java.util.concurrent.CompletableFuture.uniHandle(Unknown Source)
  101. 	at java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(Unknown Source)
  102. 	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
  103. 	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source)
  104. 	at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:261)
  105. 	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source)
  106. 	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source)
  107. 	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
  108. 	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source)
  109. 	at org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1275)
  110. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
  111. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
  112. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
  113. 	at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(Unknown Source)
  114. 	at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(Unknown Source)
  115. 	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
  116. 	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source)
  117. 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:45)
  118. 	at akka.dispatch.OnComplete.internal(Future.scala:299)
  119. 	at akka.dispatch.OnComplete.internal(Future.scala:297)
  120. 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
  121. 	at akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
  122. 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
  123. 	at org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
  124. 	at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
  125. 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
  126. 	at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
  127. 	at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
  128. 	at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
  129. 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:25)
  130. 	at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:23)
  131. 	at scala.concurrent.Future.$anonfun$andThen$1(Future.scala:532)
  132. 	at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29)
  133. 	at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29)
  134. 	at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
  135. 	at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:63)
  136. 	at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:100)
  137. 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
  138. 	at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81)
  139. 	at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:100)
  140. 	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49)
  141. 	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48)
  142. 	at java.base/java.util.concurrent.ForkJoinTask.doExec(Unknown Source)
  143. 	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(Unknown Source)
  144. 	at java.base/java.util.concurrent.ForkJoinPool.scan(Unknown Source)
  145. 	at java.base/java.util.concurrent.ForkJoinPool.runWorker(Unknown Source)
  146. 	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(Unknown Source)
  147. Caused by: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (0000000008f7fe760000000000000001)
  148. 	at org.apache.flink.runtime.dispatcher.Dispatcher.cancelJob(Dispatcher.java:749)
  149. 	at jdk.internal.reflect.GeneratedMethodAccessor250.invoke(Unknown Source)
  150. 	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
  151. 	at java.base/java.lang.reflect.Method.invoke(Unknown Source)
  152. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
  153. 	at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
  154. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
  155. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
  156. 	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
  157. 	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
  158. 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
  159. 	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
  160. 	at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
  161. 	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
  162. 	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
  163. 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
  164. 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
  165. 	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
  166. 	at akka.actor.Actor.aroundReceive(Actor.scala:537)
  167. 	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
  168. 	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
  169. 	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
  170. 	at akka.actor.ActorCell.invoke(ActorCell.scala:548)
  171. 	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
  172. 	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
  173. 	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
  174. 	... 5 more
  175. ]
  176. 	at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:534)
  177. 	at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:514)
  178. 	at java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(Unknown Source)
  179. 	at java.base/java.util.concurrent.CompletableFuture$Completion.run(Unknown Source)
  180. 	... 3 more
Compilation error #stdin compilation error #stdout 0s 0KB
comments (?)
stdin 
Standard input is empty
compilation info 
Main.java:1: error: class, interface, or enum expected
java.util.concurrent.ExecutionException: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: Job could not be found.
^
1 error
stdout 
Standard output is empty
https://ideone.com/NuAyEK
language:
Java (HotSpot 12)
created:
2 years ago
visibility:
secret

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!