API tools faq
paste
Guest User

Untitled

a guest
Aug 18th, 2016
181
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 12.80 KB | None | 0 0
raw download clone embed print report
  1. 2016-08-18 14:54:26,905 INFO org.apache.hadoop.yarn.client.RMProxy - Connecting to ResourceManager at crmaster2.ng.seznam.cz/10.28.6.14:8032
  2. 2016-08-18 14:54:27,436 WARN org.apache.hadoop.util.NativeCodeLoader - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
  3. 2016-08-18 14:54:27,674 INFO org.apache.flink.yarn.FlinkYarnClient - Using values:
  4. 2016-08-18 14:54:27,675 INFO org.apache.flink.yarn.FlinkYarnClient - TaskManager count = 3
  5. 2016-08-18 14:54:27,675 INFO org.apache.flink.yarn.FlinkYarnClient - JobManager memory = 1024
  6. 2016-08-18 14:54:27,675 INFO org.apache.flink.yarn.FlinkYarnClient - TaskManager memory = 8192
  7. 2016-08-18 14:54:28,369 INFO org.apache.flink.yarn.Utils - Copying from file:/usr/lib/flink-scala2.10/lib/flink-dist_2.10-1.0.3.jar to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/flink-dist_2.10-1.0.3.jar
  8. 2016-08-18 14:54:42,623 INFO org.apache.flink.yarn.Utils - Copying from /etc/flink/flink-conf.yaml to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/flink-conf.yaml
  9. 2016-08-18 14:54:42,658 INFO org.apache.flink.yarn.Utils - Copying from file:/usr/lib/flink-scala2.10/lib/slf4j-log4j12-1.7.7.jar to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/slf4j-log4j12-1.7.7.jar
  10. 2016-08-18 14:54:42,746 INFO org.apache.flink.yarn.Utils - Copying from file:/usr/lib/flink-scala2.10/lib/log4j-1.2.17.jar to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/log4j-1.2.17.jar
  11. 2016-08-18 14:54:42,789 INFO org.apache.flink.yarn.Utils - Copying from file:/usr/lib/flink-scala2.10/lib/flink-python_2.10-1.0.3.jar to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/flink-python_2.10-1.0.3.jar
  12. 2016-08-18 14:54:42,808 INFO org.apache.flink.yarn.Utils - Copying from file:/etc/flink/logback.xml to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/logback.xml
  13. 2016-08-18 14:54:43,034 INFO org.apache.flink.yarn.Utils - Copying from file:/etc/flink/log4j.properties to hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087/log4j.properties
  14. 2016-08-18 14:54:43,066 INFO org.apache.flink.yarn.FlinkYarnClient - Submitting application master application_1459343641357_213087
  15. 2016-08-18 14:54:43,095 INFO org.apache.hadoop.yarn.client.api.impl.YarnClientImpl - Submitted application application_1459343641357_213087
  16. 2016-08-18 14:54:43,095 INFO org.apache.flink.yarn.FlinkYarnClient - Waiting for the cluster to be allocated
  17. 2016-08-18 14:54:43,096 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  18. 2016-08-18 14:54:44,098 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  19. 2016-08-18 14:54:45,100 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  20. 2016-08-18 14:54:46,102 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  21. 2016-08-18 14:54:47,103 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  22. 2016-08-18 14:54:48,105 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  23. 2016-08-18 14:54:49,106 INFO org.apache.flink.yarn.FlinkYarnClient - Deploying cluster, current state ACCEPTED
  24. 2016-08-18 14:54:50,108 INFO org.apache.flink.yarn.FlinkYarnClient - YARN application has been deployed successfully.
  25. 2016-08-18 14:54:50,321 INFO org.apache.flink.yarn.FlinkYarnCluster - Start actor system.
  26. 2016-08-18 14:54:50,628 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
  27. 2016-08-18 14:54:50,665 INFO Remoting - Starting remoting
  28. 2016-08-18 14:54:50,791 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://[email protected]:47644]
  29. 2016-08-18 14:54:50,798 INFO org.apache.flink.runtime.util.ZooKeeperUtils - Using '/flink' as root namespace.
  30. 2016-08-18 14:54:50,858 INFO org.apache.flink.shaded.org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
  31. 2016-08-18 14:54:50,866 INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT
  32. 2016-08-18 14:54:50,866 INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=d0403162804d
  33. 2016-08-18 14:54:50,866 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_51
  34. 2016-08-18 14:54:50,866 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
  35. 2016-08-18 14:54:50,866 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/jre-8-oracle-x64/jre
  36. 2016-08-18 14:54:50,866 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/usr/lib/flink-scala2.10/lib/flink-dist_2.10-1.0.3.jar:/usr/lib/flink-scala2.10/lib/flink-python_2.10-1.0.3.jar:/usr/lib/flink-scala2.10/lib/log4j-1.2.17.jar:/usr/lib/flink-scala2.10/lib/slf4j-log4j12-1.7.7.jar::/etc/hadoop/conf:/etc/hadoop/conf
  37. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
  38. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp
  39. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
  40. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
  41. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
  42. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=3.16.0-0.bpo.4-amd64
  43. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=wa-flink
  44. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/home/wa-flink
  45. 2016-08-18 14:54:50,867 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/
  46. 2016-08-18 14:54:50,868 INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=crzoo1.ng.seznam.cz:2181,crzoo2.ng.seznam.cz,crzoo3.ng.seznam.cz sessionTimeout=60000 watcher=org.apache.flink.shaded.org.apache.curator.ConnectionState@7c2327fa
  47. 2016-08-18 14:54:50,890 INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server crzoo3.ng.seznam.cz/10.28.6.66:2181. Will not attempt to authenticate using SASL (unknown error)
  48. 2016-08-18 14:54:50,892 INFO org.apache.zookeeper.ClientCnxn - Socket connection established to crzoo3.ng.seznam.cz/10.28.6.66:2181, initiating session
  49. 2016-08-18 14:54:50,898 INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server crzoo3.ng.seznam.cz/10.28.6.66:2181, sessionid = 0x3513495d836042e, negotiated timeout = 60000
  50. 2016-08-18 14:54:50,902 INFO org.apache.flink.shaded.org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
  51. 2016-08-18 14:54:51,913 INFO org.apache.flink.yarn.FlinkYarnCluster - Start application client.
  52. 2016-08-18 14:54:51,929 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Starting ZooKeeperLeaderRetrievalService.
  53. 2016-08-18 14:55:07,076 INFO org.apache.flink.yarn.ApplicationClient - Notification about new leader address akka.tcp://[email protected]:13261/user/jobmanager with session ID 4dc8f3b7-fbab-40ad-8cfc-0867e507897f.
  54. 2016-08-18 14:55:07,077 INFO org.apache.flink.yarn.ApplicationClient - Received address of new leader akka.tcp://[email protected]:13261/user/jobmanager with session ID 4dc8f3b7-fbab-40ad-8cfc-0867e507897f.
  55. 2016-08-18 14:55:07,078 INFO org.apache.flink.yarn.ApplicationClient - Disconnect from JobManager null.
  56. 2016-08-18 14:55:07,082 INFO org.apache.flink.yarn.ApplicationClient - Trying to register at JobManager akka.tcp://[email protected]:13261/user/jobmanager.
  57. 2016-08-18 14:55:07,346 INFO org.apache.flink.yarn.ApplicationClient - Successfully registered at the JobManager Actor[akka.tcp://[email protected]:13261/user/jobmanager#846191303]
  58. 2016-08-18 14:55:07,446 INFO org.apache.flink.yarn.ApplicationClient - Remote JobManager has been stopped successfully. Stopping local application client
  59. 2016-08-18 14:55:07,450 INFO org.apache.flink.yarn.ApplicationClient - Stopped Application client.
  60. 2016-08-18 14:55:07,450 INFO org.apache.flink.yarn.ApplicationClient - Disconnect from JobManager Actor[akka.tcp://[email protected]:13261/user/jobmanager#846191303].
  61. 2016-08-18 14:55:07,451 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Stopping ZooKeeperLeaderRetrievalService.
  62. 2016-08-18 14:55:07,458 INFO org.apache.zookeeper.ZooKeeper - Session: 0x3513495d836042e closed
  63. 2016-08-18 14:55:07,458 INFO org.apache.zookeeper.ClientCnxn - EventThread shut down
  64. 2016-08-18 14:55:07,471 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
  65. 2016-08-18 14:55:07,472 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
  66. 2016-08-18 14:55:07,496 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
  67. 2016-08-18 14:55:07,516 INFO org.apache.flink.yarn.FlinkYarnCluster - Application application_1459343641357_213087 finished with state FINISHED and final state FAILED at 1471524890563
  68. 2016-08-18 14:55:09,998 WARN org.apache.flink.client.FlinkYarnSessionCli - Exception while running the interactive command line interface
  69. java.lang.RuntimeException: Unable to get Cluster status from Application Client
  70. at org.apache.flink.yarn.FlinkYarnCluster.getClusterStatus(FlinkYarnCluster.java:307)
  71. at org.apache.flink.client.FlinkYarnSessionCli.runInteractiveCli(FlinkYarnSessionCli.java:307)
  72. at org.apache.flink.client.FlinkYarnSessionCli.run(FlinkYarnSessionCli.java:465)
  73. at org.apache.flink.client.FlinkYarnSessionCli.main(FlinkYarnSessionCli.java:362)
  74. Caused by: akka.pattern.AskTimeoutException: Recipient[Actor[akka://flink/user/applicationClient#1597761169]] had already been terminated.
  75. at akka.pattern.AskableActorRef$.ask$extension(AskSupport.scala:132)
  76. at akka.pattern.AskableActorRef$.$qmark$extension(AskSupport.scala:144)
  77. at akka.pattern.AskSupport$class.ask(AskSupport.scala:75)
  78. at akka.pattern.package$.ask(package.scala:43)
  79. at akka.pattern.Patterns$.ask(Patterns.scala:47)
  80. at akka.pattern.Patterns.ask(Patterns.scala)
  81. at org.apache.flink.yarn.FlinkYarnCluster.getClusterStatus(FlinkYarnCluster.java:302)
  82. ... 3 more
  83. 2016-08-18 14:55:10,000 INFO org.apache.flink.client.FlinkYarnSessionCli - Command Line Interface requested session shutdown
  84. 2016-08-18 14:55:10,001 INFO org.apache.flink.yarn.FlinkYarnCluster - Sending shutdown request to the Application Master
  85. 2016-08-18 14:55:10,001 INFO org.apache.flink.yarn.FlinkYarnCluster - Deleting files in hdfs://crmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1459343641357_213087
  86. 2016-08-18 14:55:10,957 INFO org.apache.flink.yarn.FlinkYarnCluster - YARN Client is shutting down
Advertisement
Add Comment
Please, Sign In to add comment
Public Pastes
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!