API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Sep 15th, 2016
170
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 12.79 KB | None | 0 0
raw download clone embed print report
  1. 2016-09-15 17:35:36,372 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
  2. 2016-09-15 17:35:36,386 INFO org.apache.flink.client.CliFrontend - Starting Command Line Client (Version: 1.1.2, Rev:f42f0c6, Date:30.08.2016 @ 15:02:59 UTC)
  3. 2016-09-15 17:35:36,386 INFO org.apache.flink.client.CliFrontend - Current user: ubuntu
  4. 2016-09-15 17:35:36,386 INFO org.apache.flink.client.CliFrontend - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.111-b01
  5. 2016-09-15 17:35:36,386 INFO org.apache.flink.client.CliFrontend - Maximum heap size: 910 MiBytes
  6. 2016-09-15 17:35:36,386 INFO org.apache.flink.client.CliFrontend - JAVA_HOME: (not set)
  7. 2016-09-15 17:35:36,388 INFO org.apache.flink.client.CliFrontend - Hadoop version: 2.7.2
  8. 2016-09-15 17:35:36,399 INFO org.apache.flink.client.CliFrontend - JVM Options:
  9. 2016-09-15 17:35:36,399 INFO org.apache.flink.client.CliFrontend - -Dlog.file=/home/ubuntu/flink-1.1.2/log/flink-ubuntu-client-ip-172-31-0-4.log
  10. 2016-09-15 17:35:36,399 INFO org.apache.flink.client.CliFrontend - -Dlog4j.configuration=file:/home/ubuntu/flink-1.1.2/conf/log4j-cli.properties
  11. 2016-09-15 17:35:36,399 INFO org.apache.flink.client.CliFrontend - -Dlogback.configurationFile=file:/home/ubuntu/flink-1.1.2/conf/logback.xml
  12. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - Program Arguments:
  13. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - run
  14. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - examples/streaming/SocketWindowWordCount.jar
  15. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - --port
  16. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - 9000
  17. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - Classpath: /home/ubuntu/flink-1.1.2/lib/flink-dist_2.10-1.1.2.jar:/home/ubuntu/flink-1.1.2/lib/flink-python_2.10-1.1.2.jar:/home/ubuntu/flink-1.1.2/lib/log4j-1.2.17.jar:/home/ubuntu/flink-1.1.2/lib/slf4j-log4j12-1.7.7.jar:::
  18. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
  19. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - Using configuration directory /home/ubuntu/flink-1.1.2/conf
  20. 2016-09-15 17:35:36,400 INFO org.apache.flink.client.CliFrontend - Trying to load configuration file
  21. 2016-09-15 17:35:37,451 INFO org.apache.flink.client.CliFrontend - Running 'run' command.
  22. 2016-09-15 17:35:37,468 INFO org.apache.flink.client.CliFrontend - Building program from JAR file
  23. 2016-09-15 17:35:37,828 INFO org.apache.flink.client.CliFrontend - Cluster configuration: Standalone cluster with JobManager at /<PUBLIC_IP>:6123
  24. 2016-09-15 17:35:37,841 INFO org.apache.flink.client.CliFrontend - Using address <PUBLIC_IP>:6123 to connect to JobManager.
  25. 2016-09-15 17:35:37,843 INFO org.apache.flink.client.CliFrontend - JobManager web interface address http://<PUBLIC_IP>:8081
  26. 2016-09-15 17:35:37,843 INFO org.apache.flink.client.CliFrontend - Starting execution of program
  27. 2016-09-15 17:35:37,844 INFO org.apache.flink.client.program.StandaloneClusterClient - Starting program in interactive mode
  28. 2016-09-15 17:35:38,631 INFO org.apache.flink.client.program.StandaloneClusterClient - Submitting job with JobID: ad9d6e06ef96d3dffaa2857895dcd1db. Waiting for job completion.
  29. 2016-09-15 17:35:38,631 INFO org.apache.flink.client.program.StandaloneClusterClient - Starting client actor system.
  30. 2016-09-15 17:35:40,220 INFO org.apache.flink.runtime.net.ConnectionUtils - Trying to connect to /<PUBLIC_IP>:6123
  31. 2016-09-15 17:35:40,221 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address 'ip-172-31-0-4/172.31.0.4': Connection refused
  32. 2016-09-15 17:35:40,222 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/fe80:0:0:0:e5:b0ff:fe8b:ab1b%2': Network is unreachable
  33. 2016-09-15 17:35:40,223 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/172.31.0.4': Connection refused
  34. 2016-09-15 17:35:40,223 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/0:0:0:0:0:0:0:1%1': Network is unreachable
  35. 2016-09-15 17:35:40,223 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/127.0.0.1': Invalid argument
  36. 2016-09-15 17:35:40,224 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/fe80:0:0:0:e5:b0ff:fe8b:ab1b%2': Network is unreachable
  37. 2016-09-15 17:35:40,237 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/172.31.0.4': Connection refused
  38. 2016-09-15 17:35:40,237 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/0:0:0:0:0:0:0:1%1': Network is unreachable
  39. 2016-09-15 17:35:40,237 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/127.0.0.1': Invalid argument
  40. 2016-09-15 17:35:40,238 INFO org.apache.flink.runtime.net.ConnectionUtils - Could not connect. Waiting for 395 msecs before next attempt
  41. 2016-09-15 17:35:40,634 INFO org.apache.flink.runtime.net.ConnectionUtils - Trying to connect to /<PUBLIC_IP>:6123
  42. 2016-09-15 17:35:40,635 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address 'ip-172-31-0-4/172.31.0.4': Connection refused
  43. 2016-09-15 17:35:40,635 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/fe80:0:0:0:e5:b0ff:fe8b:ab1b%2': Network is unreachable
  44. 2016-09-15 17:35:40,636 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/172.31.0.4': Connection refused
  45. 2016-09-15 17:35:40,636 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/0:0:0:0:0:0:0:1%1': Network is unreachable
  46. 2016-09-15 17:35:40,636 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/127.0.0.1': Invalid argument
  47. 2016-09-15 17:35:40,637 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/fe80:0:0:0:e5:b0ff:fe8b:ab1b%2': Network is unreachable
  48. 2016-09-15 17:35:40,637 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/172.31.0.4': Connection refused
  49. 2016-09-15 17:35:40,637 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/0:0:0:0:0:0:0:1%1': Network is unreachable
  50. 2016-09-15 17:35:40,638 INFO org.apache.flink.runtime.net.ConnectionUtils - Failed to connect from address '/127.0.0.1': Invalid argument
  51. 2016-09-15 17:35:40,638 WARN org.apache.flink.runtime.net.ConnectionUtils - Could not connect to /<PUBLIC_IP>:6123. Selecting a local address using heuristics.
  52. 2016-09-15 17:35:41,789 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
  53. 2016-09-15 17:35:41,906 INFO Remoting - Starting remoting
  54. 2016-09-15 17:35:42,221 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@172.31.0.4:57956]
  55. 2016-09-15 17:35:42,257 INFO org.apache.flink.runtime.client.JobClientActor - Disconnect from JobManager null.
  56. 2016-09-15 17:35:42,290 INFO org.apache.flink.runtime.client.JobClientActor - Received job Socket Window WordCount (ad9d6e06ef96d3dffaa2857895dcd1db).
  57. 2016-09-15 17:35:42,290 INFO org.apache.flink.runtime.client.JobClientActor - Could not submit job Socket Window WordCount (ad9d6e06ef96d3dffaa2857895dcd1db), because there is no connection to a JobManager.
  58. 2016-09-15 17:35:42,544 WARN Remoting - Tried to associate with unreachable remote address [akka.tcp://flink@<PUBLIC_IP>:6123]. Address is now gated for 5000 ms, all messages to this address will be delivered to dead letters. Reason: Connection refused: /<PUBLIC_IP>:6123
  59. 2016-09-15 17:36:42,335 ERROR org.apache.flink.client.CliFrontend - Error while running the command.
  60. org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Communication with JobManager failed: Lost connection to the JobManager.
  61. at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:405)
  62. at org.apache.flink.client.program.StandaloneClusterClient.submitJob(StandaloneClusterClient.java:95)
  63. at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:378)
  64. at org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:68)
  65. at org.apache.flink.streaming.examples.socket.SocketWindowWordCount.main(SocketWindowWordCount.java:89)
  66. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  67. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
  68. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  69. at java.lang.reflect.Method.invoke(Method.java:606)
  70. at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:509)
  71. at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403)
  72. at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:320)
  73. at org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:777)
  74. at org.apache.flink.client.CliFrontend.run(CliFrontend.java:253)
  75. at org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1005)
  76. at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1048)
  77. Caused by: org.apache.flink.runtime.client.JobExecutionException: Communication with JobManager failed: Lost connection to the JobManager.
  78. at org.apache.flink.runtime.client.JobClient.submitJobAndWait(JobClient.java:137)
  79. at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:401)
  80. ... 15 more
  81. Caused by: org.apache.flink.runtime.client.JobClientActorConnectionTimeoutException: Lost connection to the JobManager.
  82. at org.apache.flink.runtime.client.JobClientActor.handleMessage(JobClientActor.java:252)
  83. at org.apache.flink.runtime.akka.FlinkUntypedActor.handleLeaderSessionID(FlinkUntypedActor.java:90)
  84. at org.apache.flink.runtime.akka.FlinkUntypedActor.onReceive(FlinkUntypedActor.java:70)
  85. at akka.actor.UntypedActor$$anonfun$receive$1.applyOrElse(UntypedActor.scala:167)
  86. at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
  87. at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:97)
  88. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
  89. at akka.actor.ActorCell.invoke(ActorCell.scala:487)
  90. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
  91. at akka.dispatch.Mailbox.run(Mailbox.scala:221)
  92. at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
  93. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  94. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.pollAndExecAll(ForkJoinPool.java:1253)
  95. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1346)
  96. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  97. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  98. 2016-09-15 17:36:42,349 INFO org.apache.flink.runtime.client.JobClientActor - Terminate JobClientActor.
  99. 2016-09-15 17:36:42,366 INFO org.apache.flink.runtime.client.JobClientActor - Disconnect from JobManager null.
  100. 2016-09-15 17:36:42,400 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
  101. 2016-09-15 17:36:42,400 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
  102. 2016-09-15 17:36:42,534 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!