API tools faq
paste
Guest User

Untitled

a guest
Aug 22nd, 2016
171
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 23.24 KB | None | 0 0
raw download clone embed print report
  1. Log Type: jobmanager.log
  2.  
  3. Log Upload Time: Mon Aug 22 13:02:00 +0200 2016
  4.  
  5. Log Length: 23547
  6.  
  7. 2016-08-22 13:01:54,140 INFO org.apache.flink.yarn.ApplicationMaster - YARN daemon runs as yarn setting user to execute Flink ApplicationMaster/JobManager to wa-flink
  8. 2016-08-22 13:01:54,143 INFO org.apache.flink.yarn.ApplicationMaster - --------------------------------------------------------------------------------
  9. 2016-08-22 13:01:54,143 INFO org.apache.flink.yarn.ApplicationMaster - Starting YARN ApplicationMaster/JobManager (Version: 1.0.3, Rev:62121b0, Date:07.07.2016 @ 13:45:19 CEST)
  10. 2016-08-22 13:01:54,143 INFO org.apache.flink.yarn.ApplicationMaster - Current user: yarn
  11. 2016-08-22 13:01:54,143 INFO org.apache.flink.yarn.ApplicationMaster - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.51-b03
  12. 2016-08-22 13:01:54,143 INFO org.apache.flink.yarn.ApplicationMaster - Maximum heap size: 406 MiBytes
  13. 2016-08-22 13:01:54,143 INFO org.apache.flink.yarn.ApplicationMaster - JAVA_HOME: /usr/lib/jvm/jdk-8-oracle-x64/
  14. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - Hadoop version: 2.6.0-cdh5.7.0
  15. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - JVM Options:
  16. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - -Xmx424M
  17. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - -Dlog.file=/mnt/disk2/yarn/logs/application_1470731428072_3873/container_1470731428072_3873_01_000001/jobmanager.log
  18. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - -Dlogback.configurationFile=file:logback.xml
  19. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - -Dlog4j.configuration=file:log4j.properties
  20. 2016-08-22 13:01:54,144 INFO org.apache.flink.yarn.ApplicationMaster - Program Arguments: (none)
  21. 2016-08-22 13:01:54,145 INFO org.apache.flink.yarn.ApplicationMaster - Classpath: /mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/slf4j-log4j12-1.7.7.jar:/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/log4j-1.2.17.jar:/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/flink-python_2.10-1.0.3.jar:/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/flink.jar:/etc/hadoop/conf:/usr/lib/hadoop/share/hadoop/common/*:/usr/lib/hadoop/share/hadoop/common/lib/*:/usr/lib/hadoop-hdfs/share/hadoop/hdfs/*:/usr/lib/hadoop-hdfs/share/hadoop/hdfs/lib/*:/usr/lib/hadoop-yarn/share/hadoop/yarn/*:/usr/lib/hadoop-yarn/share/hadoop/yarn/lib/*
  22. 2016-08-22 13:01:54,145 INFO org.apache.flink.yarn.ApplicationMaster - --------------------------------------------------------------------------------
  23. 2016-08-22 13:01:54,145 INFO org.apache.flink.yarn.ApplicationMaster - Registered UNIX signal handlers for [TERM, HUP, INT]
  24. 2016-08-22 13:01:54,155 INFO org.apache.flink.yarn.ApplicationMaster - Loading config from: /mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001.
  25. 2016-08-22 13:01:54,186 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager
  26. 2016-08-22 13:01:54,187 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager actor system at 10.28.2.155:22275
  27. 2016-08-22 13:01:54,537 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
  28. 2016-08-22 13:01:54,588 INFO Remoting - Starting remoting
  29. 2016-08-22 13:01:55,613 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://[email protected]:22275]
  30. 2016-08-22 13:01:55,623 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManger web frontend
  31. 2016-08-22 13:01:55,627 INFO org.apache.flink.runtime.util.ZooKeeperUtils - Using '/flink' as root namespace.
  32. 2016-08-22 13:01:55,721 INFO org.apache.flink.shaded.org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
  33. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT
  34. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=fernet597.ng.seznam.cz
  35. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_51
  36. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
  37. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/jdk-8-oracle-x64/jre
  38. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/slf4j-log4j12-1.7.7.jar:/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/log4j-1.2.17.jar:/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/flink-python_2.10-1.0.3.jar:/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001/flink.jar:/etc/hadoop/conf:/usr/lib/hadoop/share/hadoop/common/*:/usr/lib/hadoop/share/hadoop/common/lib/*:/usr/lib/hadoop-hdfs/share/hadoop/hdfs/*:/usr/lib/hadoop-hdfs/share/hadoop/hdfs/lib/*:/usr/lib/hadoop-yarn/share/hadoop/yarn/*:/usr/lib/hadoop-yarn/share/hadoop/yarn/lib/*
  39. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=:/usr/lib/hadoop/lib/native:/usr/lib/hadoop/lib/native:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
  40. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp
  41. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
  42. 2016-08-22 13:01:55,732 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
  43. 2016-08-22 13:01:55,733 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
  44. 2016-08-22 13:01:55,733 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=3.16.0-0.bpo.4-amd64
  45. 2016-08-22 13:01:55,733 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=yarn
  46. 2016-08-22 13:01:55,733 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/var/lib/hadoop-yarn
  47. 2016-08-22 13:01:55,733 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/mnt/disk2/yarn/local/usercache/wa-flink/appcache/application_1470731428072_3873/container_1470731428072_3873_01_000001
  48. 2016-08-22 13:01:55,734 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@6b8d96d9
  49. 2016-08-22 13:01:55,781 INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server crzoo1.ng.seznam.cz/10.28.6.64:2181. Will not attempt to authenticate using SASL (unknown error)
  50. 2016-08-22 13:01:55,787 INFO org.apache.zookeeper.ClientCnxn - Socket connection established to crzoo1.ng.seznam.cz/10.28.6.64:2181, initiating session
  51. 2016-08-22 13:01:55,796 INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server crzoo1.ng.seznam.cz/10.28.6.64:2181, sessionid = 0x152eec48a0002e5, negotiated timeout = 60000
  52. 2016-08-22 13:01:55,802 INFO org.apache.flink.shaded.org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
  53. 2016-08-22 13:01:56,825 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager log file: /mnt/disk2/yarn/logs/application_1470731428072_3873/container_1470731428072_3873_01_000001/jobmanager.log
  54. 2016-08-22 13:01:56,826 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager stdout file: /mnt/disk2/yarn/logs/application_1470731428072_3873/container_1470731428072_3873_01_000001/jobmanager.out
  55. 2016-08-22 13:01:56,827 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-75d06ea8-18e3-4972-8867-deb7cd63e101 for the web interface files
  56. 2016-08-22 13:01:56,827 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-upload-e67b0311-bbe2-4b69-89ad-4f7167dad47b for web frontend JAR file uploads
  57. 2016-08-22 13:01:57,069 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Web frontend listening at 0:0:0:0:0:0:0:0:43020
  58. 2016-08-22 13:01:57,069 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager actor
  59. 2016-08-22 13:01:57,073 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-9602cd93-7c3f-474d-9037-33cbb9a64293
  60. 2016-08-22 13:01:57,468 INFO org.apache.flink.runtime.blob.FileSystemBlobStore - Created blob directory hdfs:///wa/flink/recovery/blob.
  61. 2016-08-22 13:01:57,468 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:65451 - max concurrent requests: 50 - max backlog: 1000
  62. 2016-08-22 13:01:57,475 INFO org.apache.flink.runtime.util.ZooKeeperUtils - Using '/flink' as root namespace.
  63. 2016-08-22 13:01:57,476 INFO org.apache.flink.shaded.org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
  64. 2016-08-22 13:01:57,476 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@1ddd3478
  65. 2016-08-22 13:01:57,477 INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server crzoo1.ng.seznam.cz/10.28.6.64:2181. Will not attempt to authenticate using SASL (unknown error)
  66. 2016-08-22 13:01:57,478 INFO org.apache.zookeeper.ClientCnxn - Socket connection established to crzoo1.ng.seznam.cz/10.28.6.64:2181, initiating session
  67. 2016-08-22 13:01:57,480 INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server crzoo1.ng.seznam.cz/10.28.6.64:2181, sessionid = 0x152eec48a0002e6, negotiated timeout = 60000
  68. 2016-08-22 13:01:57,481 INFO org.apache.flink.shaded.org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
  69. 2016-08-22 13:01:57,497 INFO org.apache.flink.runtime.checkpoint.SavepointStoreFactory - Using job manager savepoint state backend.
  70. 2016-08-22 13:01:57,505 INFO org.apache.flink.runtime.jobmanager.MemoryArchivist - Started memory archivist akka://flink/user/archive
  71. 2016-08-22 13:01:57,507 INFO org.apache.flink.yarn.YarnJobManager - Starting JobManager at akka.tcp://[email protected]:22275/user/jobmanager.
  72. 2016-08-22 13:01:57,507 INFO org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionService - Starting ZooKeeperLeaderElectionService.
  73. 2016-08-22 13:01:57,509 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Starting with JobManager akka.tcp://[email protected]:22275/user/jobmanager on port 43020
  74. 2016-08-22 13:01:57,509 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Starting ZooKeeperLeaderRetrievalService.
  75. 2016-08-22 13:01:57,520 INFO org.apache.flink.yarn.ApplicationMaster - Generate configuration file for application master.
  76. 2016-08-22 13:01:57,532 INFO org.apache.flink.yarn.ApplicationMaster - Starting YARN session on Job Manager.
  77. 2016-08-22 13:01:57,533 INFO org.apache.flink.yarn.ApplicationMaster - Application Master properly initiated. Awaiting termination of actor system.
  78. 2016-08-22 13:01:57,545 INFO org.apache.flink.yarn.YarnJobManager - Start yarn session.
  79. 2016-08-22 13:01:57,579 INFO org.apache.flink.yarn.YarnJobManager - Yarn session with 3 TaskManagers. Tolerating 3 failed TaskManagers
  80. 2016-08-22 13:01:57,689 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - yarn.client.max-cached-nodemanagers-proxies : 0
  81. 2016-08-22 13:01:57,690 INFO org.apache.flink.yarn.YarnJobManager - Registering ApplicationMaster with tracking url http://fernet597.ng.seznam.cz:43020.
  82. 2016-08-22 13:01:57,797 INFO org.apache.flink.yarn.YarnJobManager - Retrieved 0 TaskManagers from previous attempts.
  83. 2016-08-22 13:01:57,801 INFO org.apache.flink.yarn.YarnJobManager - Requesting initial TaskManager container 0.
  84. 2016-08-22 13:01:57,810 INFO org.apache.flink.yarn.YarnJobManager - Requesting initial TaskManager container 1.
  85. 2016-08-22 13:01:57,811 INFO org.apache.flink.yarn.YarnJobManager - Requesting initial TaskManager container 2.
  86. 2016-08-22 13:01:57,820 ERROR org.apache.flink.yarn.YarnJobManager - Could not start yarn session.
  87. java.lang.IllegalArgumentException: Wrong FS: hdfs://fernetmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1470731428072_3873/flink-dist_2.10-1.0.3.jar, expected: hdfs://fernet:8020
  88. at org.apache.hadoop.fs.FileSystem.checkPath(FileSystem.java:657)
  89. at org.apache.hadoop.hdfs.DistributedFileSystem.getPathName(DistributedFileSystem.java:194)
  90. at org.apache.hadoop.hdfs.DistributedFileSystem.access$000(DistributedFileSystem.java:106)
  91. at org.apache.hadoop.hdfs.DistributedFileSystem$19.doCall(DistributedFileSystem.java:1215)
  92. at org.apache.hadoop.hdfs.DistributedFileSystem$19.doCall(DistributedFileSystem.java:1211)
  93. at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81)
  94. at org.apache.hadoop.hdfs.DistributedFileSystem.getFileStatus(DistributedFileSystem.java:1211)
  95. at org.apache.flink.yarn.Utils.registerLocalResource(Utils.java:108)
  96. at org.apache.flink.yarn.YarnJobManager$$anonfun$org$apache$flink$yarn$YarnJobManager$$startYarnSession$2.apply$mcV$sp(YarnJobManager.scala:455)
  97. at org.apache.flink.yarn.YarnJobManager$$anonfun$org$apache$flink$yarn$YarnJobManager$$startYarnSession$2.apply(YarnJobManager.scala:367)
  98. at org.apache.flink.yarn.YarnJobManager$$anonfun$org$apache$flink$yarn$YarnJobManager$$startYarnSession$2.apply(YarnJobManager.scala:367)
  99. at scala.util.Try$.apply(Try.scala:161)
  100. at org.apache.flink.yarn.YarnJobManager.org$apache$flink$yarn$YarnJobManager$$startYarnSession(YarnJobManager.scala:367)
  101. at org.apache.flink.yarn.YarnJobManager$$anonfun$handleYarnMessage$1.applyOrElse(YarnJobManager.scala:233)
  102. at scala.PartialFunction$OrElse.apply(PartialFunction.scala:162)
  103. at org.apache.flink.runtime.LeaderSessionMessageFilter$$anonfun$receive$1.applyOrElse(LeaderSessionMessageFilter.scala:44)
  104. at scala.runtime.AbstractPartialFunction$mcVL$sp.apply$mcVL$sp(AbstractPartialFunction.scala:33)
  105. at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:33)
  106. at scala.runtime.AbstractPartialFunction$mcVL$sp.apply(AbstractPartialFunction.scala:25)
  107. at org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:33)
  108. at org.apache.flink.runtime.LogMessages$$anon$1.apply(LogMessages.scala:28)
  109. at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:118)
  110. at org.apache.flink.runtime.LogMessages$$anon$1.applyOrElse(LogMessages.scala:28)
  111. at akka.actor.Actor$class.aroundReceive(Actor.scala:465)
  112. at org.apache.flink.runtime.jobmanager.JobManager.aroundReceive(JobManager.scala:107)
  113. at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)
  114. at akka.actor.ActorCell.invoke(ActorCell.scala:487)
  115. at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:254)
  116. at akka.dispatch.Mailbox.run(Mailbox.scala:221)
  117. at akka.dispatch.Mailbox.exec(Mailbox.scala:231)
  118. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  119. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  120. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  121. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
  122. 2016-08-22 13:01:57,824 INFO org.apache.flink.yarn.YarnJobManager - JobManager akka.tcp://[email protected]:22275/user/jobmanager was granted leadership with leader session ID Some(68f83df9-603b-4b09-b62c-cc9eeffbe113).
  123. 2016-08-22 13:01:57,825 WARN org.apache.flink.yarn.YarnJobManager - Discard message LeaderSessionMessage(null,StopYarnSession(FAILED,ApplicationMaster failed while starting. Exception Message: Wrong FS: hdfs://fernetmaster.ng.seznam.cz:8020/user/wa-flink/.flink/application_1470731428072_3873/flink-dist_2.10-1.0.3.jar, expected: hdfs://fernet:8020)) because the expected leader session ID Some(68f83df9-603b-4b09-b62c-cc9eeffbe113) did not equal the received leader session ID None.
  124. 2016-08-22 13:01:57,974 INFO org.apache.flink.yarn.YarnJobManager - Delaying recovery of all jobs by 10000 milliseconds.
  125. 2016-08-22 13:01:57,982 INFO org.apache.flink.runtime.webmonitor.JobManagerRetriever - New leader reachable under akka.tcp://[email protected]:22275/user/jobmanager:68f83df9-603b-4b09-b62c-cc9eeffbe113.
  126. 2016-08-22 13:01:58,853 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : fernet373.ng.seznam.cz:45454
  127. 2016-08-22 13:01:58,854 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : fernet592.ng.seznam.cz:45454
  128. 2016-08-22 13:01:58,854 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : fernet563.ng.seznam.cz:45454
  129. 2016-08-22 13:01:58,875 INFO org.apache.flink.yarn.YarnJobManager - Got new container for allocation: container_1470731428072_3873_01_000002
  130. 2016-08-22 13:01:58,875 INFO org.apache.flink.yarn.YarnJobManager - Got new container for allocation: container_1470731428072_3873_01_000003
  131. 2016-08-22 13:01:58,875 INFO org.apache.flink.yarn.YarnJobManager - Got new container for allocation: container_1470731428072_3873_01_000004
  132. 2016-08-22 13:01:58,876 INFO org.apache.flink.yarn.YarnJobManager - The user requested 3 containers, 0 running. 3 containers missing
  133. 2016-08-22 13:01:58,877 INFO org.apache.flink.yarn.YarnJobManager - 3 containers already allocated by YARN. Starting...
  134. 2016-08-22 13:01:58,877 ERROR org.apache.flink.yarn.YarnJobManager - The ContainerLaunchContext was not set.
  135. 2016-08-22 13:01:58,878 INFO org.apache.flink.yarn.YarnJobManager - There are 3 containers missing. 0 are already requested. Requesting 3 additional container(s) from YARN. Reallocation of failed containers is enabled=true ('yarn.reallocate-failed')
  136. 2016-08-22 13:01:58,879 INFO org.apache.flink.yarn.YarnJobManager - Requested additional container from YARN. Pending requests 1.
  137. 2016-08-22 13:01:58,880 INFO org.apache.flink.yarn.YarnJobManager - Requested additional container from YARN. Pending requests 2.
  138. 2016-08-22 13:01:58,880 INFO org.apache.flink.yarn.YarnJobManager - Requested additional container from YARN. Pending requests 3.
  139. 2016-08-22 13:01:58,881 INFO org.apache.flink.yarn.YarnJobManager - Stopping YARN JobManager with status FAILED and diagnostic Fatal error in AM: The ContainerLaunchContext was not set..
  140. 2016-08-22 13:01:58,890 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Waiting for application to be successfully unregistered.
  141. 2016-08-22 13:01:58,993 INFO org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl - Interrupted while waiting for queue
  142. java.lang.InterruptedException
  143. at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
  144. at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
  145. at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
  146. at org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl$CallbackHandlerThread.run(AMRMClientAsyncImpl.java:274)
  147. 2016-08-22 13:01:59,010 INFO org.apache.flink.yarn.YarnJobManager - Stopping JobManager akka.tcp://[email protected]:22275/user/jobmanager.
  148. 2016-08-22 13:01:59,012 INFO org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionService - Stopping ZooKeeperLeaderElectionService.
  149. 2016-08-22 13:01:59,022 INFO org.apache.zookeeper.ZooKeeper - Session: 0x152eec48a0002e6 closed
  150. 2016-08-22 13:01:59,022 INFO org.apache.zookeeper.ClientCnxn - EventThread shut down
  151. 2016-08-22 13:01:59,044 INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:65451
  152. 2016-08-22 13:01:59,050 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
  153. 2016-08-22 13:01:59,052 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
  154. 2016-08-22 13:01:59,075 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
  155. 2016-08-22 13:01:59,092 INFO org.apache.flink.yarn.YarnJobManager - Shutdown completed. Stopping JVM.
  156. 2016-08-22 13:01:59,093 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Stopping ZooKeeperLeaderRetrievalService.
  157. 2016-08-22 13:01:59,094 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Removing web dashboard root cache directory /tmp/flink-web-75d06ea8-18e3-4972-8867-deb7cd63e101
  158. 2016-08-22 13:01:59,094 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Removing web dashboard jar upload directory /tmp/flink-web-upload-e67b0311-bbe2-4b69-89ad-4f7167dad47b
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!