Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 15:27:04,568 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - Starting Command Line Client (Version: 0.9.0, Rev:0a35271, Date:18.06.2015 @ 10:25:59 UTC)
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - Current user: VinhJune
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.7/23.5-b02
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - Maximum heap size: 104 MiBytes
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - JAVA_HOME: /Library/Java/JavaVirtualMachines/jdk1.7.0_09.jdk/Contents/Home
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - JVM Options:
- 15:27:04,570 INFO org.apache.flink.client.CliFrontend - -Dlog.file=/Users/VinhJune/Workspace/Flink/flink-0.9.0/bin/../log/flink-VinhJune-flink-client-VJ.local.log
- 15:27:04,571 INFO org.apache.flink.client.CliFrontend - -Dlog4j.configuration=file:/Users/VinhJune/Workspace/Flink/flink-0.9.0/bin/../conf/log4j-cli.properties
- 15:27:04,571 INFO org.apache.flink.client.CliFrontend - -Dlogback.configurationFile=file:/Users/VinhJune/Workspace/Flink/flink-0.9.0/bin/../conf/logback.xml
- 15:27:04,571 INFO org.apache.flink.client.CliFrontend - Program Arguments:
- 15:27:04,571 INFO org.apache.flink.client.CliFrontend - run
- 15:27:04,571 INFO org.apache.flink.client.CliFrontend - gmql-flink-scala-1.0.jar
- 15:27:04,571 INFO org.apache.flink.client.CliFrontend - --------------------------------------------------------------------------------
- 15:27:04,572 INFO org.apache.flink.client.CliFrontend - Using configuration directory /Users/VinhJune/Workspace/Flink/flink-0.9.0/bin/../conf
- 15:27:04,572 INFO org.apache.flink.client.CliFrontend - Trying to load configuration file
- 15:27:05,014 INFO org.apache.flink.client.CliFrontend - Running 'run' command.
- 15:27:05,024 INFO org.apache.flink.client.CliFrontend - Building program from JAR file
- 15:27:05,073 INFO org.apache.flink.client.CliFrontend - Starting execution of program
- 15:27:05,073 INFO org.apache.flink.client.program.Client - Starting program in interactive mode
- 15:27:05,369 INFO org.apache.flink.api.java.ExecutionEnvironment - The job has 0 registered types and 0 default Kryo serializers
- 15:27:05,544 INFO org.apache.flink.client.program.Client - JobManager actor system address is localhost/127.0.0.1:6123
- 15:27:05,544 INFO org.apache.flink.client.program.Client - Starting client actor system
- 15:27:05,545 INFO org.apache.flink.runtime.client.JobClient - Starting JobClient actor system
- 15:27:06,029 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
- 15:27:06,081 INFO Remoting - Starting remoting
- 15:27:06,309 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:58958]
- 15:27:06,314 INFO org.apache.flink.runtime.client.JobClient - Started JobClient actor system at 127.0.0.1:58958
- 15:27:06,314 INFO org.apache.flink.client.program.Client - Looking up JobManager
- 15:27:06,786 INFO org.apache.flink.client.program.Client - JobManager runs at akka.tcp://flink@127.0.0.1:6123/user/jobmanager
- 15:27:06,787 INFO org.apache.flink.client.program.Client - Communication between client and JobManager will have a timeout of 100000 milliseconds
- 15:27:06,787 INFO org.apache.flink.client.program.Client - Checking and uploading JAR files
- 15:27:06,907 INFO org.apache.flink.runtime.client.JobClient - Sending message to JobManager akka.tcp://flink@127.0.0.1:6123/user/jobmanager to submit job Flink Java Job at Thu Jul 16 15:27:05 CEST 2015 (cce9204dc9bf22c27297a238c5d889f0) and wait for progress
- 15:27:07,006 INFO org.apache.flink.runtime.client.JobClient - Job was successfully submitted to the JobManager
- 15:27:07,010 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:06 Job execution switched to status RUNNING.
- 15:27:07,018 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:06 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.fromElements(ExecutionEnvironment.scala:505) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at vj.gmql.WordCount$.main(WordCount.scala:44)) -> Map (Map at vj.gmql.WordCount$.main(WordCount.scala:45)) -> Combine(SUM(1))(1/1) switched to SCHEDULED
- 15:27:07,020 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.fromElements(ExecutionEnvironment.scala:505) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at vj.gmql.WordCount$.main(WordCount.scala:44)) -> Map (Map at vj.gmql.WordCount$.main(WordCount.scala:45)) -> Combine(SUM(1))(1/1) switched to DEPLOYING
- 15:27:07,200 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.fromElements(ExecutionEnvironment.scala:505) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at vj.gmql.WordCount$.main(WordCount.scala:44)) -> Map (Map at vj.gmql.WordCount$.main(WordCount.scala:45)) -> Combine(SUM(1))(1/1) switched to RUNNING
- 15:27:07,227 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN Reduce (SUM(1)) -> FlatMap (collect())(1/1) switched to SCHEDULED
- 15:27:07,230 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN Reduce (SUM(1)) -> FlatMap (collect())(1/1) switched to DEPLOYING
- 15:27:07,248 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN DataSource (at org.apache.flink.api.scala.ExecutionEnvironment.fromElements(ExecutionEnvironment.scala:505) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at vj.gmql.WordCount$.main(WordCount.scala:44)) -> Map (Map at vj.gmql.WordCount$.main(WordCount.scala:45)) -> Combine(SUM(1))(1/1) switched to FINISHED
- 15:27:07,256 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN Reduce (SUM(1)) -> FlatMap (collect())(1/1) switched to RUNNING
- 15:27:07,319 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 DataSink (collect() sink)(1/1) switched to SCHEDULED
- 15:27:07,320 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 DataSink (collect() sink)(1/1) switched to DEPLOYING
- 15:27:07,321 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 CHAIN Reduce (SUM(1)) -> FlatMap (collect())(1/1) switched to FINISHED
- 15:27:07,331 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 DataSink (collect() sink)(1/1) switched to RUNNING
- 15:27:07,339 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 DataSink (collect() sink)(1/1) switched to FINISHED
- 15:27:07,340 INFO org.apache.flink.runtime.client.JobClient - 07/16/2015 15:27:07 Job execution switched to status FINISHED.
- 15:27:07,356 INFO org.apache.flink.runtime.client.JobClient - Job execution complete
- 15:27:07,375 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
- 15:27:07,377 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
- 15:27:07,411 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
- 15:27:07,436 INFO org.apache.flink.client.CliFrontend - Program execution finished
- 15:27:07,436 INFO org.apache.flink.client.CliFrontend - The Job did not return an execution result
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
