Last active
August 29, 2015 14:18
-
-
Save hsaputra/329669ddf72827db3fd2 to your computer and use it in GitHub Desktop.
Apache Flink Execution Local Stack
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Apache Flink Execution Messages (local) | |
| ======================== | |
| Executing WordCount example with built-in default data. | |
| Provide parameters to read input data from a file. | |
| Usage: WordCount <text path> <result path> | |
| 16:46:47,454 INFO org.apache.flink.api.java.ExecutionEnvironment - The job has 0 registered types and 0 default Kryo serializers | |
| 16:46:48,042 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started | |
| 16:46:48,060 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /var/folders/nv/nsr_3ysj0wgfq93fqp0rdt3w0000gp/T/blobStore-e2b96f68-ebdd-450a-b385-759f70f1b33e | |
| 16:46:48,061 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:58364 - max concurrent requests: 50 - max backlog: 1000 | |
| 16:46:48,077 INFO org.apache.flink.runtime.jobmanager.JobManager - Starting JobManager at akka://flink/user/jobmanager. | |
| 16:46:48,083 INFO org.apache.flink.runtime.taskmanager.TaskManager - Temporary file directory '/var/folders/nv/nsr_3ysj0wgfq93fqp0rdt3w0000gp/T': total 464 GB, usable 243 GB (52.37% usable) | |
| 16:46:48,083 INFO org.apache.flink.runtime.taskmanager.TaskManager - Using 1227 MB for Flink managed memory. | |
| 16:46:48,083 INFO org.apache.flink.runtime.taskmanager.TaskManager - Messages between TaskManager and JobManager have a max timeout of 100000 milliseconds | |
| 16:46:48,091 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager uses directory /var/folders/nv/nsr_3ysj0wgfq93fqp0rdt3w0000gp/T/flink-io-3cf97b12-29f4-4959-9569-27875871d349 for spill files. | |
| 16:46:48,092 INFO org.apache.flink.runtime.taskmanager.TaskManager - Starting task manager at akka://flink/user/taskmanager_1. | |
| 16:46:48,094 INFO org.apache.flink.runtime.taskmanager.TaskManager - Creating 8 task slot(s). | |
| 16:46:48,095 INFO org.apache.flink.runtime.taskmanager.TaskManager - TaskManager connection information: localhost (dataPort=58365) | |
| 16:46:49,361 INFO org.apache.flink.runtime.taskmanager.TaskManager - Profiling of jobs is disabled. | |
| 16:46:49,363 INFO org.apache.flink.runtime.taskmanager.TaskManager - Memory usage stats: [HEAP: 1244/2095/3641 MB, NON HEAP: 16/27/130 MB (used/committed/max)] | |
| 16:46:49,435 INFO org.apache.flink.runtime.taskmanager.TaskManager - Try to register at master akka://flink/user/jobmanager. 1. Attempt | |
| 16:46:49,446 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at localhost (akka://flink/user/taskmanager_1) as 4f119596f8284c2e9db97e2405691c28. Current number of registered hosts is 1. | |
| 16:46:49,465 INFO org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768). | |
| 16:46:49,467 INFO org.apache.flink.runtime.taskmanager.TaskManager - Determined BLOB server address to be localhost/127.0.0.1:58364. | |
| 16:46:49,468 INFO org.apache.flink.runtime.blob.BlobCache - Created BLOB cache storage directory /var/folders/nv/nsr_3ysj0wgfq93fqp0rdt3w0000gp/T/blobStore-e0c64015-4d5e-43b9-8269-161d25cb6998 | |
| 16:46:49,574 INFO org.apache.flink.runtime.jobmanager.JobManager - Received job f2f9838294f7cc584353fa34d06da8da (WordCount Example). | |
| 16:46:49,588 INFO org.apache.flink.runtime.jobmanager.JobManager - Scheduling job WordCount Example. | |
| 03/02/2015 16:46:49 Job execution switched to status RUNNING. | |
| 03/02/2015 16:46:49 CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67)(1/1) switched to SCHEDULED | |
| 03/02/2015 16:46:49 CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67)(1/1) switched to DEPLOYING | |
| 16:46:49,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67) (1/1) (attempt #0) to localhost | |
| 16:46:49,595 INFO org.apache.flink.runtime.jobmanager.JobManager - Status of job f2f9838294f7cc584353fa34d06da8da (WordCount Example) changed to RUNNING . | |
| 03/02/2015 16:46:49 CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67)(1/1) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(5/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(4/8) switched to SCHEDULED | |
| 16:46:49,649 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (4/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(3/8) switched to SCHEDULED | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (8/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(2/8) switched to SCHEDULED | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (2/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(1/8) switched to SCHEDULED | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (6/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(6/8) switched to SCHEDULED | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (1/8) (attempt #0) to localhost | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (3/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(8/8) switched to SCHEDULED | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (7/8) (attempt #0) to localhost | |
| 16:46:49,650 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Reduce (SUM(1), at main(WordCount.java:67) (5/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(7/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(4/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(8/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(7/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(2/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(3/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(6/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(1/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(5/8) switched to DEPLOYING | |
| 16:46:49,653 INFO org.apache.flink.runtime.taskmanager.Task - CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67) (1/1) switched to FINISHED | |
| 16:46:49,654 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67) (92187691637fb221fd5f304093e3a081) to FINISHED. | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(5/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(8/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(7/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(6/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(3/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(4/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(2/8) switched to RUNNING | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(1/8) switched to RUNNING | |
| 03/02/2015 16:46:49 CHAIN DataSource (at getDefaultTextLineDataSet(WordCountData.java:70) (org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at main(WordCount.java:67)) -> Combine(SUM(1), at main(WordCount.java:67)(1/1) switched to FINISHED | |
| 16:46:49,670 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 92187691637fb221fd5f304093e3a081. | |
| 16:46:49,727 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (8/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(8/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(8/8) switched to DEPLOYING | |
| 16:46:49,728 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (5/8) (attempt #0) to localhost | |
| 16:46:49,728 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (2/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(2/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(5/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(5/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(2/8) switched to DEPLOYING | |
| 16:46:49,729 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (7/8) (attempt #0) to localhost | |
| 16:46:49,729 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (6/8) (attempt #0) to localhost | |
| 16:46:49,729 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (4/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(7/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(4/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(6/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(7/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(4/8) switched to DEPLOYING | |
| 16:46:49,730 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (3/8) (attempt #0) to localhost | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(6/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(3/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(3/8) switched to DEPLOYING | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(8/8) switched to RUNNING | |
| 8> (fly,1) | |
| 8> (fortune,1) | |
| 8> (great,1) | |
| 8> (make,2) | |
| 8> (my,1) | |
| 8> (now,1) | |
| 8> (of,15) | |
| 8> (patient,1) | |
| 8> (proud,1) | |
| 8> (puzzles,1) | |
| 8> (resolution,1) | |
| 8> (scorns,1) | |
| 8> (sea,1) | |
| 8> (traveller,1) | |
| 8> (we,4) | |
| 8> (would,2) | |
| 16:46:49,731 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (7/8) switched to FINISHED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(5/8) switched to RUNNING | |
| 5> (after,1) | |
| 5> (arms,1) | |
| 5> (bare,1) | |
| 5> (be,4) | |
| 5> (coil,1) | |
| 5> (contumely,1) | |
| 5> (despis,1) | |
| 16:46:49,732 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (3f62792375c397b0b4eb4ecf3c34fb40) to FINISHED. | |
| 5> (dreams,1) | |
| 5> (give,1) | |
| 5> (himself,1) | |
| 5> (hue,1) | |
| 5> (know,1) | |
| 5> (moment,1) | |
| 5> (nobler,1) | |
| 5> (nymph,1) | |
| 5> (oppressor,1) | |
| 5> (so,1) | |
| 5> (the,22) | |
| 5> (their,1) | |
| 5> (thy,1) | |
| 5> (when,2) | |
| 5> (whose,1) | |
| 5> (wrong,1) | |
| 5> (you,1) | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(2/8) switched to RUNNING | |
| 2> (all,2) | |
| 2> (and,12) | |
| 2> (bear,3) | |
| 2> (bodkin,1) | |
| 2> (conscience,1) | |
| 2> (die,2) | |
| 2> (er,1) | |
| 2> (fair,1) | |
| 2> (for,2) | |
| 2> (heartache,1) | |
| 2> (life,2) | |
| 2> (long,1) | |
| 2> (lose,1) | |
| 2> (merit,1) | |
| 2> (not,2) | |
| 2> (off,1) | |
| 2> (office,1) | |
| 2> (ophelia,1) | |
| 2> (opposing,1) | |
| 2> (regard,1) | |
| 2> (s,5) | |
| 2> (take,1) | |
| 2> (time,1) | |
| 2> (turn,1) | |
| 2> (unworthy,1) | |
| 2> (wish,1) | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(7/8) switched to RUNNING | |
| 7> (action,1) | |
| 7> (against,1) | |
| 7> (bourn,1) | |
| 7> (cast,1) | |
| 7> (end,2) | |
| 7> (grunt,1) | |
| 7> (ills,1) | |
| 7> (is,3) | |
| 7> (makes,2) | |
| 7> (more,1) | |
| 7> (or,2) | |
| 16:46:49,734 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (2/8) switched to FINISHED | |
| 7> (others,1) | |
| 7> (pangs,1) | |
| 7> (question,1) | |
| 16:46:49,734 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (2/8) switched to FINISHED | |
| 7> (respect,1) | |
| 7> (that,7) | |
| 7> (troubles,1) | |
| 7> (us,3) | |
| 7> (will,1) | |
| 16:46:49,734 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (7/8) switched to FINISHED | |
| 16:46:49,735 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (3553fea79a69ce49d2ca00eb95531d87) to FINISHED. | |
| 16:46:49,735 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (323526078354cb5b6f55833d04707416) to FINISHED. | |
| 16:46:49,735 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (08866d981729976b1876420f3868bae0) to FINISHED. | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(6/8) switched to RUNNING | |
| 6> (ay,1) | |
| 6> (come,1) | |
| 6> (country,1) | |
| 6> (flesh,1) | |
| 6> (from,1) | |
| 6> (heir,1) | |
| 6> (law,1) | |
| 6> (may,1) | |
| 6> (might,1) | |
| 6> (mortal,1) | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(4/8) switched to RUNNING | |
| 6> (must,1) | |
| 6> (name,1) | |
| 6> (native,1) | |
| 6> (orisons,1) | |
| 6> (remember,1) | |
| 6> (returns,1) | |
| 6> (rub,1) | |
| 6> (say,1) | |
| 6> (spurns,1) | |
| 6> (sweat,1) | |
| 4> (calamity,1) | |
| 6> (those,1) | |
| 4> (cowards,1) | |
| 6> (thousand,1) | |
| 4> (death,2) | |
| 6> (to,15) | |
| 4> (fardels,1) | |
| 6> (undiscover,1) | |
| 4> (he,1) | |
| 6> (whips,1) | |
| 4> (his,1) | |
| 6> (with,3) | |
| 4> (insolence,1) | |
| 4> (love,1) | |
| 4> (mind,1) | |
| 4> (natural,1) | |
| 4> (quietus,1) | |
| 4> (shuffled,1) | |
| 4> (than,1) | |
| 4> (there,2) | |
| 4> (tis,2) | |
| 4> (under,1) | |
| 4> (who,2) | |
| 16:46:49,737 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (5/8) switched to FINISHED | |
| 16:46:49,737 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (5/8) switched to FINISHED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(3/8) switched to RUNNING | |
| 3> (a,5) | |
| 3> (but,1) | |
| 3> (by,2) | |
| 16:46:49,738 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (4066467fd351316c5e097da803e17a81) to FINISHED. | |
| 3> (currents,1) | |
| 3> (does,1) | |
| 3> (dread,1) | |
| 3> (dream,1) | |
| 3> (enterprises,1) | |
| 3> (o,1) | |
| 3> (outrageous,1) | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(7/8) switched to FINISHED | |
| 3> (pause,1) | |
| 16:46:49,738 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (e00439de80a1de632eebe0c7bffdd6ab) to FINISHED. | |
| 3> (perchance,1) | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(2/8) switched to FINISHED | |
| 3> (pith,1) | |
| 3> (sicklied,1) | |
| 3> (sins,1) | |
| 3> (sleep,5) | |
| 3> (slings,1) | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(2/8) switched to FINISHED | |
| 3> (takes,1) | |
| 3> (these,1) | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(7/8) switched to FINISHED | |
| 3> (this,2) | |
| 3> (what,1) | |
| 16:46:49,740 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 3f62792375c397b0b4eb4ecf3c34fb40. | |
| 16:46:49,740 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (8/8) switched to FINISHED | |
| 16:46:49,740 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (8/8) switched to FINISHED | |
| 16:46:49,741 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (9f60f084494b413aa0c20e6e15aec616) to FINISHED. | |
| 16:46:49,741 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (9ae9980de2d5fdb19735d38e2902f322) to FINISHED. | |
| 16:46:49,742 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (4/8) switched to FINISHED | |
| 16:46:49,742 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (4/8) switched to FINISHED | |
| 16:46:49,743 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (2207c873070e69427f0a422bb608452e) to FINISHED. | |
| 16:46:49,743 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (44c9f11e799d4723c58e6110ac6cab51) to FINISHED. | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(5/8) switched to FINISHED | |
| 16:46:49,744 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 3553fea79a69ce49d2ca00eb95531d87. | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(1/8) switched to SCHEDULED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(1/8) switched to DEPLOYING | |
| 16:46:49,745 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying DataSink(Print to System.out) (1/8) (attempt #0) to localhost | |
| 16:46:49,752 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (3/8) switched to FINISHED | |
| 16:46:49,752 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (3/8) switched to FINISHED | |
| 16:46:49,753 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (14bc4b182b5c070e8eabe2868284e375) to FINISHED. | |
| 16:46:49,753 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (8dde0913f6f044feef7c975871a65a5c) to FINISHED. | |
| 16:46:49,758 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (1/8) switched to FINISHED | |
| 16:46:49,758 INFO org.apache.flink.runtime.taskmanager.Task - Reduce (SUM(1), at main(WordCount.java:67) (6/8) switched to FINISHED | |
| 16:46:49,758 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (6/8) switched to FINISHED | |
| 16:46:49,758 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (336213d7c302a84ca9d4d6ec3c540395) to FINISHED. | |
| 16:46:49,758 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of Reduce (SUM(1), at main(WordCount.java:67) (956576b8af1c68a16b379270fb971394) to FINISHED. | |
| 16:46:49,758 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (c522bbf871e45b182aa53622d7fbe66c) to FINISHED. | |
| 16:46:49,759 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 323526078354cb5b6f55833d04707416. | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(5/8) switched to FINISHED | |
| 16:46:49,759 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 08866d981729976b1876420f3868bae0. | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(8/8) switched to FINISHED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(8/8) switched to FINISHED | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(4/8) switched to FINISHED | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(4/8) switched to FINISHED | |
| 16:46:49,760 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 4066467fd351316c5e097da803e17a81. | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(1/8) switched to RUNNING | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(3/8) switched to FINISHED | |
| 1> (arrows,1) | |
| 1> (awry,1) | |
| 1> (consummation,1) | |
| 1> (d,4) | |
| 1> (delay,1) | |
| 1> (devoutly,1) | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(1/8) switched to FINISHED | |
| 1> (have,2) | |
| 1> (in,3) | |
| 1> (man,1) | |
| 1> (no,2) | |
| 1> (pale,1) | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(3/8) switched to FINISHED | |
| 1> (rather,1) | |
| 1> (shocks,1) | |
| 1> (soft,1) | |
| 1> (something,1) | |
| 1> (suffer,1) | |
| 1> (them,1) | |
| 03/02/2015 16:46:49 Reduce (SUM(1), at main(WordCount.java:67)(6/8) switched to FINISHED | |
| 1> (thought,1) | |
| 1> (thus,2) | |
| 1> (weary,1) | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(6/8) switched to FINISHED | |
| 1> (whether,1) | |
| 16:46:49,763 INFO org.apache.flink.runtime.taskmanager.Task - DataSink(Print to System.out) (1/8) switched to FINISHED | |
| 16:46:49,763 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID e00439de80a1de632eebe0c7bffdd6ab. | |
| 16:46:49,763 INFO org.apache.flink.runtime.taskmanager.Task - Update execution state of DataSink(Print to System.out) (0e3bf51a39995224ca4fab137d17da5c) to FINISHED. | |
| 16:46:49,764 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 9f60f084494b413aa0c20e6e15aec616. | |
| 16:46:49,764 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 9ae9980de2d5fdb19735d38e2902f322. | |
| 16:46:49,765 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 2207c873070e69427f0a422bb608452e. | |
| 16:46:49,765 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 44c9f11e799d4723c58e6110ac6cab51. | |
| 16:46:49,766 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 14bc4b182b5c070e8eabe2868284e375. | |
| 16:46:49,767 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 8dde0913f6f044feef7c975871a65a5c. | |
| 16:46:49,767 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 336213d7c302a84ca9d4d6ec3c540395. | |
| 16:46:49,768 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 956576b8af1c68a16b379270fb971394. | |
| 16:46:49,768 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID c522bbf871e45b182aa53622d7fbe66c. | |
| 03/02/2015 16:46:49 DataSink(Print to System.out)(1/8) switched to FINISHED | |
| 16:46:49,769 INFO org.apache.flink.runtime.taskmanager.TaskManager - Unregister task with execution ID 0e3bf51a39995224ca4fab137d17da5c. | |
| 03/02/2015 16:46:49 Job execution switched to status FINISHED. | |
| 16:46:49,770 INFO org.apache.flink.runtime.jobmanager.JobManager - Status of job f2f9838294f7cc584353fa34d06da8da (WordCount Example) changed to FINISHED . | |
| 16:46:49,770 INFO org.apache.flink.runtime.minicluster.FlinkMiniCluster - Stopping FlinkMiniCluster. | |
| 16:46:49,775 INFO org.apache.flink.runtime.jobmanager.JobManager - Stopping job manager akka://flink/user/jobmanager. | |
| 16:46:49,776 INFO org.apache.flink.runtime.taskmanager.TaskManager - Stopping task manager akka://flink/user/taskmanager_1. | |
| 16:46:49,787 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory /var/folders/nv/nsr_3ysj0wgfq93fqp0rdt3w0000gp/T/flink-io-3cf97b12-29f4-4959-9569-27875871d349 |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment