Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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
- 2016-09-15 17:33:29,815 INFO org.apache.flink.runtime.jobmanager.JobManager - --------------------------------------------------------------------------------
- 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)
- 2016-09-15 17:33:29,815 INFO org.apache.flink.runtime.jobmanager.JobManager - Current user: ubuntu
- 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
- 2016-09-15 17:33:29,815 INFO org.apache.flink.runtime.jobmanager.JobManager - Maximum heap size: 247 MiBytes
- 2016-09-15 17:33:29,815 INFO org.apache.flink.runtime.jobmanager.JobManager - JAVA_HOME: (not set)
- 2016-09-15 17:33:29,821 INFO org.apache.flink.runtime.jobmanager.JobManager - Hadoop version: 2.7.2
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - JVM Options:
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - -Xms256m
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - -Xmx256m
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - -XX:MaxPermSize=256m
- 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
- 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
- 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
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - Program Arguments:
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - --configDir
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - /home/ubuntu/flink-1.1.2/conf
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - --executionMode
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - cluster
- 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:::
- 2016-09-15 17:33:29,822 INFO org.apache.flink.runtime.jobmanager.JobManager - --------------------------------------------------------------------------------
- 2016-09-15 17:33:29,838 INFO org.apache.flink.runtime.jobmanager.JobManager - Registered UNIX signal handlers for [TERM, HUP, INT]
- 2016-09-15 17:33:30,268 INFO org.apache.flink.runtime.jobmanager.JobManager - Loading configuration from /home/ubuntu/flink-1.1.2/conf
- 2016-09-15 17:33:30,293 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager without high-availability
- 2016-09-15 17:33:30,311 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager on <PUBLIC_IP>:6123 with execution mode CLUSTER
- 2016-09-15 17:33:30,736 INFO org.apache.flink.runtime.jobmanager.JobManager - Security is not enabled. Starting non-authenticated JobManager.
- 2016-09-15 17:33:30,766 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager
- 2016-09-15 17:33:30,767 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager actor system at <PUBLIC_IP>:6123
- 2016-09-15 17:33:32,159 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
- 2016-09-15 17:33:32,327 INFO Remoting - Starting remoting
- 2016-09-15 17:33:32,740 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@<PUBLIC_IP>:6123]
- 2016-09-15 17:33:32,758 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager web frontend
- 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
- 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
- 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
- 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
- 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
- 2016-09-15 17:33:33,582 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager actor
- 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
- 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
- 2016-09-15 17:33:33,610 INFO org.apache.flink.runtime.checkpoint.savepoint.SavepointStoreFactory - Using job manager savepoint state backend.
- 2016-09-15 17:33:33,632 INFO org.apache.flink.runtime.metrics.MetricRegistry - No metrics reporter configured, no metrics will be exposed/reported.
- 2016-09-15 17:33:33,638 INFO org.apache.flink.runtime.jobmanager.MemoryArchivist - Started memory archivist akka://flink/user/archive
- 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.
- 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
- 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.
- 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
- 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.
- 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
- ~
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement