fork download
copy 
  1. {"errors":["org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application.
  2. 	at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$1(JarRunHandler.java:113)
  3. 	at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
  4. 	at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
  5. 	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
  6. 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1609)
  7. 	at java.lang.Thread.run(Thread.java:750)
  8. Caused by: java.util.concurrent.CompletionException: org.apache.flink.util.FlinkRuntimeException: Could not execute application.
  9. 	at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
  10. 	at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
  11. 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606)
  12. 	... 1 more
  13. Caused by: org.apache.flink.util.FlinkRuntimeException: Could not execute application.
  14. 	at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:88)
  15. 	at org.apache.flink.client.deployment.application.DetachedApplicationRunner.run(DetachedApplicationRunner.java:70)
  16. 	at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$0(JarRunHandler.java:107)
  17. 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
  18. 	... 1 more
  19. Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Job client must be a CoordinationRequestGateway. This is a bug.
  20. 	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
  21. 	at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
  22. 	at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:98)
  23. 	at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84)
  24. 	... 4 more
  25. Caused by: java.lang.IllegalArgumentException: Job client must be a CoordinationRequestGateway. This is a bug.
  26. 	at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138)
  27. 	at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.setJobClient(CollectResultFetcher.java:90)
  28. 	at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.setJobClient(CollectResultIterator.java:101)
  29. 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.lambda$executeAsync$14(StreamExecutionEnvironment.java:2193)
  30. 	at java.util.ArrayList.forEach(ArrayList.java:1259)
  31. 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2193)
  32. 	at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:206)
  33. 	at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2169)
  34. 	at org.apache.flink.streaming.api.datastream.DataStream.executeAndCollectWithClient(DataStream.java:1469)
  35. 	at org.apache.flink.streaming.api.datastream.DataStream.executeAndCollect(DataStream.java:1334)
  36. 	at org.apache.flink.streaming.api.datastream.DataStream.executeAndCollect(DataStream.java:1320)
  37.  
  38. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  39. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  40. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  41. 	at java.lang.reflect.Method.invoke(Method.java:498)
  42. 	at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
  43. 	... 7 more
  44. "]}
  45.  
Compilation error #stdin compilation error #stdout 0s 0KB
comments (?)
stdin
copy 
Standard input is empty
compilation info 
Main.java:1: error: class, interface, or enum expected
{"errors":["org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application.
^
Main.java:1: error: unclosed string literal
{"errors":["org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application.
           ^
Main.java:44: error: unclosed string literal
"]}
^
3 errors
stdout
copy 
Standard output is empty
https://ideone.com/LdtTmE
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!