Advertisement
Guest User

Untitled

a guest
Sep 15th, 2016
114
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. 16-09-15 17:33:29,134 WARN  org.apache.hadoop.util.NativeCodeLoader                       - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
  2. 2016-09-15 17:33:29,815 INFO  org.apache.flink.runtime.jobmanager.JobManager                - --------------------------------------------------------------------------------
  3. 2016-09-15 17:33:29,815 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  Starting JobManager (Version: 1.1.2, Rev:f42f0c6, Date:30.08.2016 @ 15:02:59 UTC)
  4. 2016-09-15 17:33:29,815 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  Current user: ubuntu
  5. 2016-09-15 17:33:29,815 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.111-b01
  6. 2016-09-15 17:33:29,815 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  Maximum heap size: 247 MiBytes
  7. 2016-09-15 17:33:29,815 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  JAVA_HOME: (not set)
  8. 2016-09-15 17:33:29,821 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  Hadoop version: 2.7.2
  9. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  JVM Options:
  10. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     -Xms256m
  11. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     -Xmx256m
  12. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     -XX:MaxPermSize=256m
  13. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     -Dlog.file=/home/ubuntu/flink-1.1.2/log/flink-ubuntu-jobmanager-2-ip-172-31-0-4.log
  14. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     -Dlog4j.configuration=file:/home/ubuntu/flink-1.1.2/conf/log4j.properties
  15. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     -Dlogback.configurationFile=file:/home/ubuntu/flink-1.1.2/conf/logback.xml
  16. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  Program Arguments:
  17. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     --configDir
  18. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     /home/ubuntu/flink-1.1.2/conf
  19. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     --executionMode
  20. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -     cluster
  21. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                -  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:::
  22. 2016-09-15 17:33:29,822 INFO  org.apache.flink.runtime.jobmanager.JobManager                - --------------------------------------------------------------------------------
  23. 2016-09-15 17:33:29,838 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Registered UNIX signal handlers for [TERM, HUP, INT]
  24. 2016-09-15 17:33:30,268 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Loading configuration from /home/ubuntu/flink-1.1.2/conf
  25. 2016-09-15 17:33:30,293 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager without high-availability
  26. 2016-09-15 17:33:30,311 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager on <PUBLIC_IP>:6123 with execution mode CLUSTER
  27. 2016-09-15 17:33:30,736 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Security is not enabled. Starting non-authenticated JobManager.
  28. 2016-09-15 17:33:30,766 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager
  29. 2016-09-15 17:33:30,767 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager actor system at <PUBLIC_IP>:6123
  30. 2016-09-15 17:33:32,159 INFO  akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger started
  31. 2016-09-15 17:33:32,327 INFO  Remoting                                                      - Starting remoting
  32. 2016-09-15 17:33:32,740 INFO  Remoting                                                      - Remoting started; listening on addresses :[akka.tcp://flink@<PUBLIC_IP>:6123]
  33. 2016-09-15 17:33:32,758 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager web frontend
  34. 2016-09-15 17:33:32,802 INFO  org.apache.flink.runtime.webmonitor.WebMonitorUtils           - Determined location of JobManager log file: /home/ubuntu/flink-1.1.2/log/flink-ubuntu-jobmanager-2-ip-172-31-0-4.log
  35. 2016-09-15 17:33:32,802 INFO  org.apache.flink.runtime.webmonitor.WebMonitorUtils           - Determined location of JobManager stdout file: /home/ubuntu/flink-1.1.2/log/flink-ubuntu-jobmanager-2-ip-172-31-0-4.out
  36. 2016-09-15 17:33:32,820 INFO  org.apache.flink.runtime.webmonitor.WebRuntimeMonitor         - Using directory /tmp/flink-web-f2041384-66b1-4cbb-9733-8cf3cd90f70a for the web interface files
  37. 2016-09-15 17:33:32,820 INFO  org.apache.flink.runtime.webmonitor.WebRuntimeMonitor         - Using directory /tmp/flink-web-upload-ea331e7e-8d52-45cd-9f30-e0fa8f9af5d6 for web frontend JAR file uploads
  38. 2016-09-15 17:33:33,581 INFO  org.apache.flink.runtime.webmonitor.WebRuntimeMonitor         - Web frontend listening at 0:0:0:0:0:0:0:0:8081
  39. 2016-09-15 17:33:33,582 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager actor
  40. 2016-09-15 17:33:33,586 INFO  org.apache.flink.runtime.blob.BlobServer                      - Created BLOB server storage directory /tmp/blobStore-2873b81b-844b-4eae-8a33-9c1ad2d913b7
  41. 2016-09-15 17:33:33,587 INFO  org.apache.flink.runtime.blob.BlobServer                      - Started BLOB server at 0.0.0.0:44666 - max concurrent requests: 50 - max backlog: 1000
  42. 2016-09-15 17:33:33,610 INFO  org.apache.flink.runtime.checkpoint.savepoint.SavepointStoreFactory  - Using job manager savepoint state backend.
  43. 2016-09-15 17:33:33,632 INFO  org.apache.flink.runtime.metrics.MetricRegistry               - No metrics reporter configured, no metrics will be exposed/reported.
  44. 2016-09-15 17:33:33,638 INFO  org.apache.flink.runtime.jobmanager.MemoryArchivist           - Started memory archivist akka://flink/user/archive
  45. 2016-09-15 17:33:33,656 INFO  org.apache.flink.runtime.jobmanager.JobManager                - Starting JobManager at akka.tcp://flink@<PUBLIC_IP>:6123/user/jobmanager.
  46. 2016-09-15 17:33:33,661 INFO  org.apache.flink.runtime.webmonitor.WebRuntimeMonitor         - Starting with JobManager akka.tcp://flink@<PUBLIC_IP>:6123/user/jobmanager on port 8081
  47. 2016-09-15 17:33:33,661 INFO  org.apache.flink.runtime.webmonitor.JobManagerRetriever       - New leader reachable under akka.tcp://flink@<PUBLIC_IP>:6123/user/jobmanager:null.
  48. 2016-09-15 17:33:33,712 INFO  org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager  - Trying to associate with JobManager leader akka.tcp://flink@<PUBLIC_IP>:6123/user/jobmanager
  49. 2016-09-15 17:33:33,830 INFO  org.apache.flink.runtime.jobmanager.JobManager                - JobManager akka.tcp://flink@<PUBLIC_IP>:6123/user/jobmanager was granted leadership with leader session ID None.
  50. 2016-09-15 17:33:33,855 INFO  org.apache.flink.runtime.clusterframework.standalone.StandaloneResourceManager  - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager#480630459] - leader session null
  51. ~
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement