RocksDB IO error

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

RocksDB IO error

zhenhao.li
Hi team,

Could you please investigate on this? It seems that we may face data loss when using RocksDB with enableFullyAsyncSnapshots.
It was Flink 1.1.3.

Regards,
Zhenhao



2016-11-03 13:42:47,071 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24) (e7f285485da95aaf42d634a8340ef692) switched from RUNNING to FAILED
2016-11-03 13:42:47,071 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (4f40190f5340b685c1e43c57e462a745) switched from RUNNING to CANCELING
2016-11-03 13:42:47,071 INFO  org.apache.flink.yarn.YarnJobManager                          - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Query_Engine) changed to FAILING.
java.lang.RuntimeException: Unable to find a leader for partitions: [Partition: KafkaTopicPartition{topic='raw_log_prod', partition=12}, KafkaPartitionHandle=[raw_log_prod,12], offset=13291723]
        at org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher.findLeaderForPartitions(Kafka08Fetcher.java:453)
        at org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher.runFetchLoop(Kafka08Fetcher.java:184)
        at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:240)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:80)
        at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:53)
        at org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
        at java.lang.Thread.run(Thread.java:745)
2016-11-03 13:42:47,071 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (3b71c9111769678b9fcd55ab15778eb2) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (6a232b503d9d21a6ad069d2760115616) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (ad2186f1447f72d2066d3f7e20ae9343) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (d932b2c9eeaf8a28d12630c51aa61ff5) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (1bcf1913643f83879b8eb94588898813) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (02cbc25dece24970d1e87b9549499834) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (66a59bc422fb3132ab7747e04b36d064) switched from RUNNING to CANCELING
2016-11-03 13:42:47,072 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (257e6c5fb4c8b5465958508aa74fbf26) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24) (88ef2e009895f1fcd4bf93fc05eb88bd) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24) (02dabd198974c85617c18fb271ef1ea7) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24) (90a713fd5dbccb33cf9c909c059feb69) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24) (a73da99ee13391c99db6f1997843c4f9) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24) (2759f49abeeaea4795f6b51d07fe7948) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24) (72f825013459bad6280af21daf5cf8be) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24) (07b1043609b0f37476b7af581d27182f) switched from RUNNING to CANCELING
2016-11-03 13:42:47,073 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24) (ba9628f18848bc12c58a6b2ad1421550) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24) (c0ffb1341439d97469fee8b2400be031) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24) (002727749f2dfc5c027b3a130a62f909) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24) (626f071febc35ee677519c17db27e639) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24) (bb39943f87c2543545cbf6fe4c51868b) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24) (6128fa7b3629ae4f712e188d677dc3ba) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24) (f5cde73e13011e459ed8fb67ec7c6936) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24) (20691339482ef2975a8aafa58bea2327) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24) (52b76f0d9680d7d51b5bb8a000cde9b2) switched from RUNNING to CANCELING
2016-11-03 13:42:47,074 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24) (fa07e74406ed7f894ad3f40c3a8b5c7c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24) (ef54f380b80f5154827e5e4a2ca0d26c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24) (2e0b64f839368a56430447fcf3d021b4) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24) (25cb281f31736ed3374dd0ddacbd6410) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24) (a705eda503df72135faebbcbf6ff3b50) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24) (f02aeea2b57678885203f025d5505a14) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24) (b04e4010ea3f9836b5173c5c904a54d6) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24) (902d697b6196fb4fb4e42dc3e10dff2e) switched from RUNNING to CANCELING
2016-11-03 13:42:47,075 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24) (925a32f2d260c91debb211a9e4bdd950) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24) (2a6fde4972073924fea473a9e4f351d8) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24) (88c63f793aa4348764a4ad3f949fdfc9) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24) (375968643fd929aac19c5a9ef85738d3) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24) (acd3dbc304ddf6184721c8c24d1027d4) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24) (07147b57eb7a0aa75434b0c1253dc7a0) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24) (3e68a564f9292dda58bad464e9fb2605) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24) (1946356177df8086e4514ffd811f9309) switched from RUNNING to CANCELING
2016-11-03 13:42:47,076 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24) (2cd85be968f6a8b7ec00b57319b22075) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24) (b46d81f3850846d334af4498e2971596) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24) (e003ab4b29181900820dd4c78bba5b42) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24) (fc140c374ab270c3907143ac04a62419) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24) (0995c67b6fc9dee9f4d37d5794a5550c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24) (c03b0183ee6939a90e54719f8c857223) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (b56ad1de01fd610a21448aa6d904137a) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (63ada3e9d24c6582324778b65330268c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (e7691dcd8165f4df11b7674f01c77fb3) switched from RUNNING to CANCELING
2016-11-03 13:42:47,077 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (8223acac0433316a595def80881d7fef) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (d45731149b0a57499a195b7db49fd2e6) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (725d7ebf870cd425215a0f69beda892b) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (2a78a3764c5cb50c30cd2b750b2d12c2) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (5ba4294fcaa08e972a46bb2abd75dde3) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (edfbc825731b434f904f06098c129dfe) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (59573a3d480f4c4c25dbd553edef7eff) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (24822849627b681f56f7c327393fc8d2) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (12726096e3b8d3f125a6e6c9a91eb729) switched from RUNNING to CANCELING
2016-11-03 13:42:47,078 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ea4dcd81466172eb6b7972489eff897c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (3e34df26676687d87e3215432dc00f51) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (92dd5c5bb3a6e50965ef3900efa134bd) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (ca54cee421ddb67962a369cafa9d532a) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (2600fedee2b14a309e9a81761fcc4a59) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ba6831817b3b7aeb918e67416f01a5aa) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (e1b21f03b7dba0fccca778e1a7d1519b) switched from RUNNING to CANCELING
2016-11-03 13:42:47,079 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (636dd3de17bc2d6f08f1f0da08eba58e) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (6837f134eb74536e5092de110689c5ce) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (59a00091f4d063e6bc9c809e54afa1d3) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (e962ced55951bf695f0b1fe5629912c5) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (41fb0267c6a18256b770ade5a5fbde3e) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (e4e860b6be3f4f364266cbd3af20a154) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (bc2176debe67db69e54403e4fe70e7d6) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24) (a73da99ee13391c99db6f1997843c4f9) switched from CANCELING to CANCELED
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (1b2a99a4efc52201d20a4c678938f3d4) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (c48870a8cc3460ed0052281b1a3ff964) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (e0f380d9e90c44591056f7bd9bc1d2a3) switched from RUNNING to CANCELING
2016-11-03 13:42:47,080 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (42156a2c610fe455c27e50e377816ffa) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (51efcc87dde178b498fd6e07b75b88a2) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (ed980803b091e73687dd0be751354f69) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (ccf24c53e3188fe92acd480af49b2fb5) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (64c9ab7f7350fbcb054054a5f31fd6c9) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (bc4a23d4a1d251b4215c15a126cc0d47) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (05bcd51f35ceb57292bffaf57ff424f5) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ebb5d517f966f535241dac389dcffec3) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (22e6571c51c1292dcf78597b3f7eed0c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (94bd1b1f69f72971a9c7c551b5f0f61c) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (3b2a57dfc9dbfe2210f95c32cec33af2) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (d97b945c9fe5add0301aed02fcb58646) switched from RUNNING to CANCELING
2016-11-03 13:42:47,081 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (24972489627b0e1b261fd6ee183b47cc) switched from RUNNING to CANCELING
2016-11-03 13:42:47,082 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (9d263d3b7ebb7a9d316ac075c20a7fba) switched from RUNNING to CANCELING
2016-11-03 13:42:47,082 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (83b7d36a7bd0960772532bcdceaf5e88) switched from RUNNING to CANCELING
2016-11-03 13:42:47,082 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (88d5ba9698387989f27f7c68c5539cf6) switched from RUNNING to CANCELING
2016-11-03 13:42:47,082 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (7ca8b68a6478f6774b6141cd4154d053) switched from RUNNING to CANCELING
2016-11-03 13:42:47,082 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (925f74401292ce293caadbac4e353efb) switched from RUNNING to CANCELING
2016-11-03 13:42:47,082 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (46579e2315960422d172cb33c426f920) switched from RUNNING to CANCELING
2016-11-03 13:42:47,083 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (3e34df26676687d87e3215432dc00f51) switched from CANCELING to CANCELED
2016-11-03 13:42:47,085 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (24822849627b681f56f7c327393fc8d2) switched from CANCELING to CANCELED
2016-11-03 13:42:47,085 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (92dd5c5bb3a6e50965ef3900efa134bd) switched from CANCELING to CANCELED
2016-11-03 13:42:47,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24) (c0ffb1341439d97469fee8b2400be031) switched from CANCELING to CANCELED
2016-11-03 13:42:47,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (725d7ebf870cd425215a0f69beda892b) switched from CANCELING to CANCELED
2016-11-03 13:42:47,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24) (20691339482ef2975a8aafa58bea2327) switched from CANCELING to CANCELED
2016-11-03 13:42:47,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24) (52b76f0d9680d7d51b5bb8a000cde9b2) switched from CANCELING to CANCELED
2016-11-03 13:42:47,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24) (fa07e74406ed7f894ad3f40c3a8b5c7c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,087 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24) (ef54f380b80f5154827e5e4a2ca0d26c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,090 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ea4dcd81466172eb6b7972489eff897c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (636dd3de17bc2d6f08f1f0da08eba58e) switched from CANCELING to CANCELED
2016-11-03 13:42:47,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (2a78a3764c5cb50c30cd2b750b2d12c2) switched from CANCELING to CANCELED
2016-11-03 13:42:47,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (d45731149b0a57499a195b7db49fd2e6) switched from CANCELING to CANCELED
2016-11-03 13:42:47,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24) (25cb281f31736ed3374dd0ddacbd6410) switched from CANCELING to CANCELED
2016-11-03 13:42:47,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24) (002727749f2dfc5c027b3a130a62f909) switched from CANCELING to CANCELED
2016-11-03 13:42:47,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (64c9ab7f7350fbcb054054a5f31fd6c9) switched from CANCELING to CANCELED
2016-11-03 13:42:47,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24) (f02aeea2b57678885203f025d5505a14) switched from CANCELING to CANCELED
2016-11-03 13:42:47,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24) (2e0b64f839368a56430447fcf3d021b4) switched from CANCELING to CANCELED
2016-11-03 13:42:47,098 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24) (a705eda503df72135faebbcbf6ff3b50) switched from CANCELING to CANCELED
2016-11-03 13:42:47,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (bc4a23d4a1d251b4215c15a126cc0d47) switched from CANCELING to CANCELED
2016-11-03 13:42:47,106 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (8223acac0433316a595def80881d7fef) switched from CANCELING to CANCELED
2016-11-03 13:42:47,107 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (12726096e3b8d3f125a6e6c9a91eb729) switched from CANCELING to CANCELED
2016-11-03 13:42:47,109 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (e962ced55951bf695f0b1fe5629912c5) switched from CANCELING to CANCELED
2016-11-03 13:42:47,110 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (e7691dcd8165f4df11b7674f01c77fb3) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24) (72f825013459bad6280af21daf5cf8be) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (ad2186f1447f72d2066d3f7e20ae9343) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24) (626f071febc35ee677519c17db27e639) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24) (88ef2e009895f1fcd4bf93fc05eb88bd) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24) (375968643fd929aac19c5a9ef85738d3) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (9d263d3b7ebb7a9d316ac075c20a7fba) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24) (88c63f793aa4348764a4ad3f949fdfc9) switched from CANCELING to CANCELED
2016-11-03 13:42:47,111 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24) (acd3dbc304ddf6184721c8c24d1027d4) switched from CANCELING to CANCELED
2016-11-03 13:42:47,112 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24) (07147b57eb7a0aa75434b0c1253dc7a0) switched from CANCELING to CANCELED
2016-11-03 13:42:47,112 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (24972489627b0e1b261fd6ee183b47cc) switched from CANCELING to CANCELED
2016-11-03 13:42:47,112 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (ccf24c53e3188fe92acd480af49b2fb5) switched from CANCELING to CANCELED
2016-11-03 13:42:47,116 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (ebb5d517f966f535241dac389dcffec3) switched from CANCELING to CANCELED
2016-11-03 13:42:47,118 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (22e6571c51c1292dcf78597b3f7eed0c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,119 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (2600fedee2b14a309e9a81761fcc4a59) switched from CANCELING to CANCELED
2016-11-03 13:42:47,120 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (41fb0267c6a18256b770ade5a5fbde3e) switched from CANCELING to CANCELED
2016-11-03 13:42:47,120 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ba6831817b3b7aeb918e67416f01a5aa) switched from CANCELING to CANCELED
2016-11-03 13:42:47,121 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (e0f380d9e90c44591056f7bd9bc1d2a3) switched from CANCELING to CANCELED
2016-11-03 13:42:47,121 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (6a232b503d9d21a6ad069d2760115616) switched from CANCELING to CANCELED
2016-11-03 13:42:47,121 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (6837f134eb74536e5092de110689c5ce) switched from CANCELING to CANCELED
2016-11-03 13:42:47,121 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24) (f5cde73e13011e459ed8fb67ec7c6936) switched from CANCELING to CANCELED
2016-11-03 13:42:47,121 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24) (2759f49abeeaea4795f6b51d07fe7948) switched from CANCELING to CANCELED
2016-11-03 13:42:47,121 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24) (b04e4010ea3f9836b5173c5c904a54d6) switched from CANCELING to CANCELED
2016-11-03 13:42:47,122 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (63ada3e9d24c6582324778b65330268c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,122 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24) (2a6fde4972073924fea473a9e4f351d8) switched from CANCELING to CANCELED
2016-11-03 13:42:47,122 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24) (925a32f2d260c91debb211a9e4bdd950) switched from CANCELING to CANCELED
2016-11-03 13:42:47,122 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24) (902d697b6196fb4fb4e42dc3e10dff2e) switched from CANCELING to CANCELED
2016-11-03 13:42:47,122 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (94bd1b1f69f72971a9c7c551b5f0f61c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,122 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (257e6c5fb4c8b5465958508aa74fbf26) switched from CANCELING to CANCELED
2016-11-03 13:42:47,123 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (5ba4294fcaa08e972a46bb2abd75dde3) switched from CANCELING to CANCELED
2016-11-03 13:42:47,123 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (59a00091f4d063e6bc9c809e54afa1d3) switched from CANCELING to CANCELED
2016-11-03 13:42:47,125 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (59573a3d480f4c4c25dbd553edef7eff) switched from CANCELING to CANCELED
2016-11-03 13:42:47,125 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (b56ad1de01fd610a21448aa6d904137a) switched from CANCELING to CANCELED
2016-11-03 13:42:47,127 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (e4e860b6be3f4f364266cbd3af20a154) switched from CANCELING to CANCELED
2016-11-03 13:42:47,127 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (e1b21f03b7dba0fccca778e1a7d1519b) switched from CANCELING to CANCELED
2016-11-03 13:42:47,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24) (02dabd198974c85617c18fb271ef1ea7) switched from CANCELING to CANCELED
2016-11-03 13:42:47,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (d932b2c9eeaf8a28d12630c51aa61ff5) switched from CANCELING to CANCELED
2016-11-03 13:42:47,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (3b71c9111769678b9fcd55ab15778eb2) switched from CANCELING to CANCELED
2016-11-03 13:42:47,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (edfbc825731b434f904f06098c129dfe) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (42156a2c610fe455c27e50e377816ffa) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (05bcd51f35ceb57292bffaf57ff424f5) switched from CANCELING to CANCELED
2016-11-03 13:42:47,128 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (ca54cee421ddb67962a369cafa9d532a) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24) (90a713fd5dbccb33cf9c909c059feb69) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24) (ba9628f18848bc12c58a6b2ad1421550) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24) (07b1043609b0f37476b7af581d27182f) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24) (e003ab4b29181900820dd4c78bba5b42) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24) (1946356177df8086e4514ffd811f9309) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24) (6128fa7b3629ae4f712e188d677dc3ba) switched from CANCELING to CANCELED
2016-11-03 13:42:47,129 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24) (2cd85be968f6a8b7ec00b57319b22075) switched from CANCELING to CANCELED
2016-11-03 13:42:47,130 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24) (b46d81f3850846d334af4498e2971596) switched from CANCELING to CANCELED
2016-11-03 13:42:47,130 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24) (3e68a564f9292dda58bad464e9fb2605) switched from CANCELING to CANCELED
2016-11-03 13:42:47,130 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (925f74401292ce293caadbac4e353efb) switched from CANCELING to CANCELED
2016-11-03 13:42:47,130 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24) (fc140c374ab270c3907143ac04a62419) switched from CANCELING to CANCELED
2016-11-03 13:42:47,131 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24) (bb39943f87c2543545cbf6fe4c51868b) switched from CANCELING to CANCELED
2016-11-03 13:42:47,131 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24) (0995c67b6fc9dee9f4d37d5794a5550c) switched from CANCELING to CANCELED
2016-11-03 13:42:47,132 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24) (c03b0183ee6939a90e54719f8c857223) switched from CANCELING to CANCELED
2016-11-03 13:42:47,132 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (c48870a8cc3460ed0052281b1a3ff964) switched from CANCELING to CANCELED
2016-11-03 13:42:47,132 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (7ca8b68a6478f6774b6141cd4154d053) switched from CANCELING to CANCELED
2016-11-03 13:42:47,133 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (83b7d36a7bd0960772532bcdceaf5e88) switched from CANCELING to CANCELED
2016-11-03 13:42:47,133 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (1b2a99a4efc52201d20a4c678938f3d4) switched from CANCELING to CANCELED
2016-11-03 13:42:47,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (d97b945c9fe5add0301aed02fcb58646) switched from CANCELING to CANCELED
2016-11-03 13:42:47,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (bc2176debe67db69e54403e4fe70e7d6) switched from CANCELING to CANCELED
2016-11-03 13:42:47,140 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (51efcc87dde178b498fd6e07b75b88a2) switched from CANCELING to CANCELED
2016-11-03 13:42:47,140 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (88d5ba9698387989f27f7c68c5539cf6) switched from CANCELING to CANCELED
2016-11-03 13:42:47,144 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (3b2a57dfc9dbfe2210f95c32cec33af2) switched from CANCELING to CANCELED
2016-11-03 13:42:47,146 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (46579e2315960422d172cb33c426f920) switched from CANCELING to CANCELED
2016-11-03 13:42:47,156 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (ed980803b091e73687dd0be751354f69) switched from CANCELING to CANCELED
2016-11-03 13:42:47,160 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (1bcf1913643f83879b8eb94588898813) switched from CANCELING to CANCELED
2016-11-03 13:42:47,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (02cbc25dece24970d1e87b9549499834) switched from CANCELING to CANCELED
2016-11-03 13:42:47,297 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (4f40190f5340b685c1e43c57e462a745) switched from CANCELING to CANCELED
2016-11-03 13:42:48,223 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (66a59bc422fb3132ab7747e04b36d064) switched from CANCELING to CANCELED
2016-11-03 13:42:48,223 INFO  org.apache.flink.runtime.executiongraph.restart.ExecutionGraphRestarter  - Delaying retry of job execution for 10000 ms ...
2016-11-03 13:42:48,223 INFO  org.apache.flink.yarn.YarnJobManager                          - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Query_Engine) changed to RESTARTING.
2016-11-03 13:42:58,224 INFO  org.apache.flink.yarn.YarnJobManager                          - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Query_Engine) changed to CREATED.
2016-11-03 13:42:58,224 INFO  org.apache.flink.yarn.YarnJobManager                          - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Query_Engine) changed to RUNNING.
2016-11-03 13:42:58,224 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,224 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (2b99eb238bd3e8612dd1dc2393ac5428) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (2b99eb238bd3e8612dd1dc2393ac5428) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (0d1559814918cb456c304ccf3030b0f7) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (0d1559814918cb456c304ccf3030b0f7) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (910271b03af991b3427cd1100f99a064) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (910271b03af991b3427cd1100f99a064) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (b39571fd91ad48de7f2f7d3600350404) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (b39571fd91ad48de7f2f7d3600350404) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,225 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (c9a12b9d6be6b43b59bf854164051515) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (c9a12b9d6be6b43b59bf854164051515) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (84d185938655476323407afc3be9cb07) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (84d185938655476323407afc3be9cb07) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (e016baf5af215a3d524cd9513d1ba63d) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (e016baf5af215a3d524cd9513d1ba63d) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (7bc9c8563ab4fb5c55bd70d7c541e314) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (7bc9c8563ab4fb5c55bd70d7c541e314) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,226 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24) (fca5bc78f05504a5199289afed8a5923) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24) (fca5bc78f05504a5199289afed8a5923) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24) (6a38e04d57245634ba6cce91a6c98ac4) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24) (6a38e04d57245634ba6cce91a6c98ac4) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24) (bc2bea1a21655b7f03415522840da8d3) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24) (bc2bea1a21655b7f03415522840da8d3) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24) (a0ecaff73a6c3ebc0fd557887e778eb5) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24) (a0ecaff73a6c3ebc0fd557887e778eb5) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24) (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24) (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24) (8d7df0c283c259a8fb95812d1bc78608) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24) (8d7df0c283c259a8fb95812d1bc78608) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24) (b359c281228c857cd49b5af1bfc82290) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24) (b359c281228c857cd49b5af1bfc82290) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24) (ec709d95b8456210cdd821846b2f1ee2) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24) (ec709d95b8456210cdd821846b2f1ee2) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24) (bd3c09b0d4a580ede8e4d8fab88cf807) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24) (bd3c09b0d4a580ede8e4d8fab88cf807) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24) (46072d491d7c11f1e4406da939407aeb) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24) (46072d491d7c11f1e4406da939407aeb) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24) (72f3aad0236dca73a172766d2a4afa1c) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24) (72f3aad0236dca73a172766d2a4afa1c) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24) (2b529d27d0989aaa45e74847900b9bd2) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24) (2b529d27d0989aaa45e74847900b9bd2) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24) (cc2c67552af2d54e3e412f2fd453042e) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24) (cc2c67552af2d54e3e412f2fd453042e) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24) (10494b739882ad7feb43e0247190dfc6) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24) (10494b739882ad7feb43e0247190dfc6) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24) (06b7fceb9df52ee6643c788061f11261) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,229 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24) (06b7fceb9df52ee6643c788061f11261) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24) (aeeea1e1eeea141ae6199e927a568dfe) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24) (aeeea1e1eeea141ae6199e927a568dfe) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24) (c275f7f1fcbc1f448d8c976c5b7e161b) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24) (c275f7f1fcbc1f448d8c976c5b7e161b) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24) (96d5901b42e3d90546c565fa87737333) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24) (96d5901b42e3d90546c565fa87737333) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24) (827355f9c98cd9962be947578327da87) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24) (827355f9c98cd9962be947578327da87) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,230 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24) (eb87d63985d400312d84205dd3a08e21) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24) (eb87d63985d400312d84205dd3a08e21) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24) (f46bf849d5a73caffb2ab07b7820f915) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24) (f46bf849d5a73caffb2ab07b7820f915) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24) (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24) (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24) (9b17e65e7bea2384cf92ae625f2addf8) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24) (9b17e65e7bea2384cf92ae625f2addf8) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24) (0984ebe3d594a7009916c2e95ea5d532) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24) (0984ebe3d594a7009916c2e95ea5d532) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24) (daee6064608145b06088666b7babdca7) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,231 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24) (daee6064608145b06088666b7babdca7) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24) (76624c6abd0769f75eaa07711d44e964) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24) (76624c6abd0769f75eaa07711d44e964) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24) (f448c1bf173ea7f12dc02e4b18c3545c) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24) (f448c1bf173ea7f12dc02e4b18c3545c) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24) (7e606bd4b24076d8c14d44b03676cc6b) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24) (7e606bd4b24076d8c14d44b03676cc6b) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24) (290f3384e4819ca8a209c288de0de498) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24) (290f3384e4819ca8a209c288de0de498) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24) (1d6ce9ffc4e430064271d408cc8bc29a) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,232 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24) (1d6ce9ffc4e430064271d408cc8bc29a) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24) (27592f00a6cd545d043eccffb00bb19d) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24) (27592f00a6cd545d043eccffb00bb19d) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24) (024d06427a98144a85b3fd7168e49d45) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24) (024d06427a98144a85b3fd7168e49d45) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24) (d5abd030d970fe399c0bbb60885ab8f2) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24) (d5abd030d970fe399c0bbb60885ab8f2) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24) (ed5e99e3763c6750a7cab5f1032dd746) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24) (ed5e99e3763c6750a7cab5f1032dd746) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24) (c8bff8478ae3788bad8ce5af463735e3) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,233 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24) (c8bff8478ae3788bad8ce5af463735e3) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24) (778de29fb0826a276340ae284531c179) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24) (778de29fb0826a276340ae284531c179) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24) (fdfa402e13b4914493fa04c153f415ff) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24) (fdfa402e13b4914493fa04c153f415ff) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (9882efa4e42ab981527f5111f80692ff) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (c60a887f493cf6e95a78dfb4e7375c46) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (9882efa4e42ab981527f5111f80692ff) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (4bf8a429fc44579751cbe964ffcfbaa0) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (d426f245f247e09e292353675f213d28) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (7aae31976d48d69f1e77ad54e4aa93b1) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (db8e88b7ce833f5a3652ee7ecb285103) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (84a67e77b96e81c59a5af0cf41c8bbea) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (7e8fce0aa62eb2279a8b228aa8f2d375) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (4b75e618f2de1b527863250a918c6b7e) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (c60a887f493cf6e95a78dfb4e7375c46) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,236 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (4b75e618f2de1b527863250a918c6b7e) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (82e7e8883e9d32b7f71022f4e1fe925e) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (6acf1ab559e8582dc60a54b4b37d6728) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (f3641e77026ce337dd7b75eaad5841c2) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (01d8a2749f51e2e30bafaa12724ff631) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24) (254a1d29bae123c554d0b0c5c113bf3f) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (0dfd37bdb6a1b26d519a7beac04a1164) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (9c3bf96bf0595a898ba2ea8b58af2092) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (0dfd37bdb6a1b26d519a7beac04a1164) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (81693344e2c2a9a8ca92e9ad4da9dc11) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (2b99eb238bd3e8612dd1dc2393ac5428) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (9c3bf96bf0595a898ba2ea8b58af2092) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24) (254a1d29bae123c554d0b0c5c113bf3f) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (01d8a2749f51e2e30bafaa12724ff631) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (f3641e77026ce337dd7b75eaad5841c2) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (6acf1ab559e8582dc60a54b4b37d6728) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,237 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (82e7e8883e9d32b7f71022f4e1fe925e) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,236 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (7bc9c8563ab4fb5c55bd70d7c541e314) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,236 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (84d185938655476323407afc3be9cb07) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (d6eb3065ca19775516da7c8621b3cb58) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (7e8fce0aa62eb2279a8b228aa8f2d375) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (84a67e77b96e81c59a5af0cf41c8bbea) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (db8e88b7ce833f5a3652ee7ecb285103) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,235 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (7aae31976d48d69f1e77ad54e4aa93b1) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (1c50624a7caa9f2fc253927633c4625c) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (8f658ae6b80ea55549b42db50a86953c) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (4a906e18975415d514443341568ace88) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (546b61c32e7a9f12188622c76efaece2) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (9497478f64c68ae37d53795ee6594de9) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (546b61c32e7a9f12188622c76efaece2) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (4bf8a429fc44579751cbe964ffcfbaa0) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24) (daee6064608145b06088666b7babdca7) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ed455b41f40894d8c75fe01873e21126) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (d426f245f247e09e292353675f213d28) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ed455b41f40894d8c75fe01873e21126) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (5177ee682491dc7f93b1bb4f2a0ddb99) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,234 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (29bcca6a60b068e1e6891827d1be8efd) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (5177ee682491dc7f93b1bb4f2a0ddb99) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (29bcca6a60b068e1e6891827d1be8efd) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (9497478f64c68ae37d53795ee6594de9) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24) (0984ebe3d594a7009916c2e95ea5d532) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (4a906e18975415d514443341568ace88) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (b5d04c3a253ccea139af5f66df5e1423) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (8f658ae6b80ea55549b42db50a86953c) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,243 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (b5d04c3a253ccea139af5f66df5e1423) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (1c50624a7caa9f2fc253927633c4625c) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24) (2b529d27d0989aaa45e74847900b9bd2) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,240 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (85e9c2d6dcfd289c15e4b59c404a9ced) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24) (8d7df0c283c259a8fb95812d1bc78608) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (d6eb3065ca19775516da7c8621b3cb58) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (f1e0a533af1afa0ff698f3bf9db7b294) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (59c07c061529ca27485272f69b14d942) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,239 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (0d1559814918cb456c304ccf3030b0f7) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (3c26447b675a7c01e0d3ab9e8c9281e7) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (3c26447b675a7c01e0d3ab9e8c9281e7) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24) (f0febafb5535d67a50d9f8c3225d7d98) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (e016baf5af215a3d524cd9513d1ba63d) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (a2487e25fb076c97a9bc80a686168e0e) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,238 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (81693344e2c2a9a8ca92e9ad4da9dc11) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (a2487e25fb076c97a9bc80a686168e0e) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24) (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24) (f0febafb5535d67a50d9f8c3225d7d98) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (97d5575ea2503adced5fe58b452f9436) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (6fa9416df26c842f7fd14a66aa05f182) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1f4285e85b1faf6030b1256d43dd7cce) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (59c07c061529ca27485272f69b14d942) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (6c88b2507f7fed1f3c0f69fa75f89869) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (f1e0a533af1afa0ff698f3bf9db7b294) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (6c88b2507f7fed1f3c0f69fa75f89869) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (7e6af277adf044a6757a02d6c5a8be67) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (85e9c2d6dcfd289c15e4b59c404a9ced) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24) (6a38e04d57245634ba6cce91a6c98ac4) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,247 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (b84141277cae159ac4241dc6aa89d189) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24) (46072d491d7c11f1e4406da939407aeb) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (b39571fd91ad48de7f2f7d3600350404) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,244 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,247 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24) (76624c6abd0769f75eaa07711d44e964) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,243 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,243 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,243 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24) (fca5bc78f05504a5199289afed8a5923) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,243 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (d9eef1ea95ae5fbd921442d3c722d586) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24) (f448c1bf173ea7f12dc02e4b18c3545c) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,242 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (643a6c8128d3783b767110b65e6c3e0d) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (643a6c8128d3783b767110b65e6c3e0d) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,242 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (fb48d6f89abfa27e3fd26868e746369a) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,242 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (55397b724a8e9c325d377f5912d8f281) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (fb48d6f89abfa27e3fd26868e746369a) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,242 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (910271b03af991b3427cd1100f99a064) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,242 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (86523bbdc396790b03f7f6d541eea648) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,242 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,241 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24) (a0ecaff73a6c3ebc0fd557887e778eb5) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24) (aeeea1e1eeea141ae6199e927a568dfe) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (86523bbdc396790b03f7f6d541eea648) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24) (ec709d95b8456210cdd821846b2f1ee2) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24) (b359c281228c857cd49b5af1bfc82290) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (55397b724a8e9c325d377f5912d8f281) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (ba6709cbb744df73f7ea620e216bac4a) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (8079e2e2ff7d57e9acedbc483e48c9dd) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24) (10494b739882ad7feb43e0247190dfc6) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (d9eef1ea95ae5fbd921442d3c722d586) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,247 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (b84141277cae159ac4241dc6aa89d189) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,247 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,247 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (7e6af277adf044a6757a02d6c5a8be67) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,251 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (attempt #10) to cldnode04
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1f4285e85b1faf6030b1256d43dd7cce) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (97d5575ea2503adced5fe58b452f9436) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,251 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (attempt #10) to cldnode08
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (6fa9416df26c842f7fd14a66aa05f182) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (a88f821b4ed237a03f97bd17cb700b3b) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (779f97a0113a018f9af791a2e2d3d7d7) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d3bc045c09b340496db0b5c3c3) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24) (72f3aad0236dca73a172766d2a4afa1c) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,252 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d3bc045c09b340496db0b5c3c3) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,246 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (e94bd27b797bdc19ad468ae97cf47863) switched from CREATED to SCHEDULED
2016-11-03 13:42:58,245 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,252 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (e94bd27b797bdc19ad468ae97cf47863) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,252 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,251 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (779f97a0113a018f9af791a2e2d3d7d7) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,252 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,251 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (a88f821b4ed237a03f97bd17cb700b3b) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,252 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,251 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,251 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (attempt #10) to cldnode03
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (c9a12b9d6be6b43b59bf854164051515) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (attempt #10) to cldnode06
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (8079e2e2ff7d57e9acedbc483e48c9dd) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (ba6709cbb744df73f7ea620e216bac4a) switched from SCHEDULED to DEPLOYING
2016-11-03 13:42:58,250 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24) (7e606bd4b24076d8c14d44b03676cc6b) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,249 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24) (cc2c67552af2d54e3e412f2fd453042e) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,253 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,253 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (attempt #10) to cldnode05
2016-11-03 13:42:58,253 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24) (eb87d63985d400312d84205dd3a08e21) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,252 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (attempt #10) to cldnode07
2016-11-03 13:42:58,256 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24) (96d5901b42e3d90546c565fa87737333) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,256 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24) (c275f7f1fcbc1f448d8c976c5b7e161b) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,257 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24) (827355f9c98cd9962be947578327da87) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,258 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24) (290f3384e4819ca8a209c288de0de498) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,259 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24) (1d6ce9ffc4e430064271d408cc8bc29a) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,259 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24) (bc2bea1a21655b7f03415522840da8d3) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,260 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24) (bd3c09b0d4a580ede8e4d8fab88cf807) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,260 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24) (f46bf849d5a73caffb2ab07b7820f915) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,261 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24) (024d06427a98144a85b3fd7168e49d45) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,261 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24) (d5abd030d970fe399c0bbb60885ab8f2) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,262 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24) (27592f00a6cd545d043eccffb00bb19d) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,262 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24) (06b7fceb9df52ee6643c788061f11261) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,263 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24) (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,267 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (82e7e8883e9d32b7f71022f4e1fe925e) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,267 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (4b75e618f2de1b527863250a918c6b7e) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,268 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24) (9b17e65e7bea2384cf92ae625f2addf8) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,268 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (84a67e77b96e81c59a5af0cf41c8bbea) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,268 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (7aae31976d48d69f1e77ad54e4aa93b1) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,268 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (db8e88b7ce833f5a3652ee7ecb285103) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,268 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (7e8fce0aa62eb2279a8b228aa8f2d375) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,269 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24) (778de29fb0826a276340ae284531c179) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,271 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24) (ed5e99e3763c6750a7cab5f1032dd746) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,271 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (a2487e25fb076c97a9bc80a686168e0e) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,272 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (15/24) (9497478f64c68ae37d53795ee6594de9) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,272 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (ed455b41f40894d8c75fe01873e21126) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,273 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (5177ee682491dc7f93b1bb4f2a0ddb99) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,273 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (29bcca6a60b068e1e6891827d1be8efd) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,273 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (779f97a0113a018f9af791a2e2d3d7d7) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,273 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24) (c8bff8478ae3788bad8ce5af463735e3) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,274 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (3c26447b675a7c01e0d3ab9e8c9281e7) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,274 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24) (fdfa402e13b4914493fa04c153f415ff) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,276 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (18/24) (a88f821b4ed237a03f97bd17cb700b3b) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,280 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24) (254a1d29bae123c554d0b0c5c113bf3f) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,280 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (0dfd37bdb6a1b26d519a7beac04a1164) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,280 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (9c3bf96bf0595a898ba2ea8b58af2092) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,280 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (01d8a2749f51e2e30bafaa12724ff631) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,281 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (59c07c061529ca27485272f69b14d942) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,282 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (23/24) (fb48d6f89abfa27e3fd26868e746369a) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,282 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (14/24) (97d5575ea2503adced5fe58b452f9436) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,283 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (d426f245f247e09e292353675f213d28) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,283 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (9882efa4e42ab981527f5111f80692ff) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,283 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (643a6c8128d3783b767110b65e6c3e0d) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,283 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (2/24) (c60a887f493cf6e95a78dfb4e7375c46) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,286 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (4bf8a429fc44579751cbe964ffcfbaa0) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,300 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (9/24) (6acf1ab559e8582dc60a54b4b37d6728) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,300 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (f3641e77026ce337dd7b75eaad5841c2) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,300 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (20/24) (6c88b2507f7fed1f3c0f69fa75f89869) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,300 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (7e6af277adf044a6757a02d6c5a8be67) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,301 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (13/24) (6fa9416df26c842f7fd14a66aa05f182) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,301 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (12/24) (1f4285e85b1faf6030b1256d43dd7cce) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,304 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (3/24) (d6eb3065ca19775516da7c8621b3cb58) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,304 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (6/24) (b5d04c3a253ccea139af5f66df5e1423) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,304 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (f1e0a533af1afa0ff698f3bf9db7b294) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,305 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (85e9c2d6dcfd289c15e4b59c404a9ced) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,305 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (19/24) (546b61c32e7a9f12188622c76efaece2) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,306 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24) (f0febafb5535d67a50d9f8c3225d7d98) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,310 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d3bc045c09b340496db0b5c3c3) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,310 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (16/24) (e94bd27b797bdc19ad468ae97cf47863) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,311 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (21/24) (b84141277cae159ac4241dc6aa89d189) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,311 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (5/24) (81693344e2c2a9a8ca92e9ad4da9dc11) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,311 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (10/24) (d9eef1ea95ae5fbd921442d3c722d586) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,313 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (1c50624a7caa9f2fc253927633c4625c) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,314 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (4a906e18975415d514443341568ace88) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,315 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (11/24) (8f658ae6b80ea55549b42db50a86953c) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,316 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (8/24) (55397b724a8e9c325d377f5912d8f281) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,319 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (7/24) (86523bbdc396790b03f7f6d541eea648) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,320 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (24/24) (ba6709cbb744df73f7ea620e216bac4a) switched from DEPLOYING to RUNNING
2016-11-03 13:42:58,324 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (22/24) (8079e2e2ff7d57e9acedbc483e48c9dd) switched from DEPLOYING to RUNNING
2016-11-03 13:43:01,806 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat Map -> Map -> Sink: Unnamed (17/24) (620b28d3bc045c09b340496db0b5c3c3) switched from RUNNING to FAILED
2016-11-03 13:43:01,807 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (8a477f7a9f26ae73f92a45a5692939cd) switched from RUNNING to CANCELING
2016-11-03 13:43:01,807 INFO  org.apache.flink.yarn.YarnJobManager                          - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09 (Prod_Query_Engine) changed to FAILING.
java.lang.Exception: Could not restore checkpointed state to operators and functions
        at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreState(StreamTask.java:552)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:250)
        at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
        at java.lang.Thread.run(Thread.java:745)
Caused by: org.rocksdb.RocksDBException: IO error: /data/1/yarn/nm/usercache/build/appcache/application_1475672282170_2572/flink-io-53ce70e0-0541-4681-949b-a92d86a4a69d/597b4f8d8fc825cfbfaba9419cbb7e09/StreamMap_13_16/dummy_state/e305d426-0248-4f02-9541-5f2ce613b9b9/db/000058.log: No such file or directory
        at org.rocksdb.RocksDB.put(Native Method)
        at org.rocksdb.RocksDB.put(RocksDB.java:416)
        at org.apache.flink.contrib.streaming.state.RocksDBStateBackend.restoreFromFullyAsyncSnapshot(RocksDBStateBackend.java:600)
        at org.apache.flink.contrib.streaming.state.RocksDBStateBackend.injectKeyValueStateSnapshots(RocksDBStateBackend.java:493)
        at org.apache.flink.streaming.api.operators.AbstractStreamOperator.restoreState(AbstractStreamOperator.java:202)
        at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.restoreState(AbstractUdfStreamOperator.java:154)
        at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreState(StreamTask.java:544)
        ... 3 more

________________________________

This message is for the designated recipient only and may contain privileged, proprietary, or otherwise confidential information. If you have received it in error, please notify the sender immediately and delete the original. Any other use of the e-mail by you is prohibited. Where allowed by local law, electronic communications with Accenture and its affiliates, including e-mail and instant messaging (including content), may be scanned by our systems for the purposes of information security and assessment of internal compliance with Accenture policy.
______________________________________________________________________________________

www.accenture.com
Reply | Threaded
Open this post in threaded view
|

Re: RocksDB IO error

Aljoscha Krettek-2
Hi Zhenhao,
does this happen reproducibly? What happens after the failure? Will it
retry restoring and then succeed?

I have a suspicion that Yarn could be cleaning up some files that RocksDB
expects to be there while restoring.

Cheers,
Aljoscha

On Thu, 10 Nov 2016 at 14:24 <[hidden email]> wrote:

> Hi team,
>
> Could you please investigate on this? It seems that we may face data loss
> when using RocksDB with enableFullyAsyncSnapshots.
> It was Flink 1.1.3.
>
> Regards,
> Zhenhao
>
>
>
> 2016-11-03 13:42:47,071 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24)
> (e7f285485da95aaf42d634a8340ef692) switched from RUNNING to FAILED
> 2016-11-03 13:42:47,071 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24)
> (4f40190f5340b685c1e43c57e462a745) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,071 INFO  org.apache.flink.yarn.YarnJobManager
>                   - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09
> (Prod_Query_Engine) changed to FAILING.
> java.lang.RuntimeException: Unable to find a leader for partitions:
> [Partition: KafkaTopicPartition{topic='raw_log_prod', partition=12},
> KafkaPartitionHandle=[raw_log_prod,12], offset=13291723]
>         at
> org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher.findLeaderForPartitions(Kafka08Fetcher.java:453)
>         at
> org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher.runFetchLoop(Kafka08Fetcher.java:184)
>         at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.run(FlinkKafkaConsumerBase.java:240)
>         at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:80)
>         at
> org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:53)
>         at
> org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:56)
>         at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266)
>         at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
>         at java.lang.Thread.run(Thread.java:745)
> 2016-11-03 13:42:47,071 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24)
> (3b71c9111769678b9fcd55ab15778eb2) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24)
> (6a232b503d9d21a6ad069d2760115616) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24)
> (ad2186f1447f72d2066d3f7e20ae9343) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24)
> (d932b2c9eeaf8a28d12630c51aa61ff5) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24)
> (1bcf1913643f83879b8eb94588898813) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24)
> (02cbc25dece24970d1e87b9549499834) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24)
> (66a59bc422fb3132ab7747e04b36d064) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,072 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24)
> (257e6c5fb4c8b5465958508aa74fbf26) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24)
> (88ef2e009895f1fcd4bf93fc05eb88bd) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24)
> (02dabd198974c85617c18fb271ef1ea7) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24)
> (90a713fd5dbccb33cf9c909c059feb69) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24)
> (a73da99ee13391c99db6f1997843c4f9) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24)
> (2759f49abeeaea4795f6b51d07fe7948) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24)
> (72f825013459bad6280af21daf5cf8be) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24)
> (07b1043609b0f37476b7af581d27182f) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,073 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24)
> (ba9628f18848bc12c58a6b2ad1421550) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24)
> (c0ffb1341439d97469fee8b2400be031) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24)
> (002727749f2dfc5c027b3a130a62f909) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24)
> (626f071febc35ee677519c17db27e639) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24)
> (bb39943f87c2543545cbf6fe4c51868b) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24)
> (6128fa7b3629ae4f712e188d677dc3ba) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24)
> (f5cde73e13011e459ed8fb67ec7c6936) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24)
> (20691339482ef2975a8aafa58bea2327) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24)
> (52b76f0d9680d7d51b5bb8a000cde9b2) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,074 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24)
> (fa07e74406ed7f894ad3f40c3a8b5c7c) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24)
> (ef54f380b80f5154827e5e4a2ca0d26c) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24)
> (2e0b64f839368a56430447fcf3d021b4) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24)
> (25cb281f31736ed3374dd0ddacbd6410) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24)
> (a705eda503df72135faebbcbf6ff3b50) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24)
> (f02aeea2b57678885203f025d5505a14) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24)
> (b04e4010ea3f9836b5173c5c904a54d6) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24)
> (902d697b6196fb4fb4e42dc3e10dff2e) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,075 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24)
> (925a32f2d260c91debb211a9e4bdd950) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24)
> (2a6fde4972073924fea473a9e4f351d8) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24)
> (88c63f793aa4348764a4ad3f949fdfc9) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24)
> (375968643fd929aac19c5a9ef85738d3) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24)
> (acd3dbc304ddf6184721c8c24d1027d4) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24)
> (07147b57eb7a0aa75434b0c1253dc7a0) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24)
> (3e68a564f9292dda58bad464e9fb2605) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24)
> (1946356177df8086e4514ffd811f9309) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,076 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24)
> (2cd85be968f6a8b7ec00b57319b22075) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24)
> (b46d81f3850846d334af4498e2971596) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24)
> (e003ab4b29181900820dd4c78bba5b42) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24)
> (fc140c374ab270c3907143ac04a62419) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24)
> (0995c67b6fc9dee9f4d37d5794a5550c) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24)
> (c03b0183ee6939a90e54719f8c857223) switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (1/24) (b56ad1de01fd610a21448aa6d904137a)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (2/24) (63ada3e9d24c6582324778b65330268c)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (3/24) (e7691dcd8165f4df11b7674f01c77fb3)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,077 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (4/24) (8223acac0433316a595def80881d7fef)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (5/24) (d45731149b0a57499a195b7db49fd2e6)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (6/24) (725d7ebf870cd425215a0f69beda892b)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (7/24) (2a78a3764c5cb50c30cd2b750b2d12c2)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (8/24) (5ba4294fcaa08e972a46bb2abd75dde3)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (9/24) (edfbc825731b434f904f06098c129dfe)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (10/24) (59573a3d480f4c4c25dbd553edef7eff)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (11/24) (24822849627b681f56f7c327393fc8d2)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (12/24) (12726096e3b8d3f125a6e6c9a91eb729)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,078 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (13/24) (ea4dcd81466172eb6b7972489eff897c)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (14/24) (3e34df26676687d87e3215432dc00f51)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (15/24) (92dd5c5bb3a6e50965ef3900efa134bd)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (16/24) (ca54cee421ddb67962a369cafa9d532a)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (17/24) (2600fedee2b14a309e9a81761fcc4a59)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (18/24) (ba6831817b3b7aeb918e67416f01a5aa)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (19/24) (e1b21f03b7dba0fccca778e1a7d1519b)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,079 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (20/24) (636dd3de17bc2d6f08f1f0da08eba58e)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (21/24) (6837f134eb74536e5092de110689c5ce)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (22/24) (59a00091f4d063e6bc9c809e54afa1d3)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (23/24) (e962ced55951bf695f0b1fe5629912c5)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (24/24) (41fb0267c6a18256b770ade5a5fbde3e)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (1/24) (e4e860b6be3f4f364266cbd3af20a154)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (2/24) (bc2176debe67db69e54403e4fe70e7d6)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24)
> (a73da99ee13391c99db6f1997843c4f9) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (3/24) (1b2a99a4efc52201d20a4c678938f3d4)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (4/24) (c48870a8cc3460ed0052281b1a3ff964)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (5/24) (e0f380d9e90c44591056f7bd9bc1d2a3)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,080 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (6/24) (42156a2c610fe455c27e50e377816ffa)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (7/24) (51efcc87dde178b498fd6e07b75b88a2)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (8/24) (ed980803b091e73687dd0be751354f69)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (9/24) (ccf24c53e3188fe92acd480af49b2fb5)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (10/24) (64c9ab7f7350fbcb054054a5f31fd6c9)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (11/24) (bc4a23d4a1d251b4215c15a126cc0d47)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (12/24) (05bcd51f35ceb57292bffaf57ff424f5)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (13/24) (ebb5d517f966f535241dac389dcffec3)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (14/24) (22e6571c51c1292dcf78597b3f7eed0c)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (15/24) (94bd1b1f69f72971a9c7c551b5f0f61c)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (16/24) (3b2a57dfc9dbfe2210f95c32cec33af2)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (17/24) (d97b945c9fe5add0301aed02fcb58646)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,081 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (18/24) (24972489627b0e1b261fd6ee183b47cc)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,082 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (19/24) (9d263d3b7ebb7a9d316ac075c20a7fba)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,082 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (20/24) (83b7d36a7bd0960772532bcdceaf5e88)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,082 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (21/24) (88d5ba9698387989f27f7c68c5539cf6)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,082 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (22/24) (7ca8b68a6478f6774b6141cd4154d053)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,082 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (23/24) (925f74401292ce293caadbac4e353efb)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,082 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (24/24) (46579e2315960422d172cb33c426f920)
> switched from RUNNING to CANCELING
> 2016-11-03 13:42:47,083 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (14/24) (3e34df26676687d87e3215432dc00f51)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,085 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (11/24) (24822849627b681f56f7c327393fc8d2)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,085 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (15/24) (92dd5c5bb3a6e50965ef3900efa134bd)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,087 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24)
> (c0ffb1341439d97469fee8b2400be031) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,087 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (6/24) (725d7ebf870cd425215a0f69beda892b)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,087 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24)
> (20691339482ef2975a8aafa58bea2327) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,087 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24)
> (52b76f0d9680d7d51b5bb8a000cde9b2) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,087 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24)
> (fa07e74406ed7f894ad3f40c3a8b5c7c) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,087 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24)
> (ef54f380b80f5154827e5e4a2ca0d26c) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,090 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (13/24) (ea4dcd81466172eb6b7972489eff897c)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,092 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (20/24) (636dd3de17bc2d6f08f1f0da08eba58e)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,092 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (7/24) (2a78a3764c5cb50c30cd2b750b2d12c2)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,097 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (5/24) (d45731149b0a57499a195b7db49fd2e6)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,097 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24)
> (25cb281f31736ed3374dd0ddacbd6410) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,097 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24)
> (002727749f2dfc5c027b3a130a62f909) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,097 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (10/24) (64c9ab7f7350fbcb054054a5f31fd6c9)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,097 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24)
> (f02aeea2b57678885203f025d5505a14) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,097 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24)
> (2e0b64f839368a56430447fcf3d021b4) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,098 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24)
> (a705eda503df72135faebbcbf6ff3b50) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,103 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (11/24) (bc4a23d4a1d251b4215c15a126cc0d47)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,106 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (4/24) (8223acac0433316a595def80881d7fef)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,107 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (12/24) (12726096e3b8d3f125a6e6c9a91eb729)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,109 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (23/24) (e962ced55951bf695f0b1fe5629912c5)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,110 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (3/24) (e7691dcd8165f4df11b7674f01c77fb3)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24)
> (72f825013459bad6280af21daf5cf8be) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24)
> (ad2186f1447f72d2066d3f7e20ae9343) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24)
> (626f071febc35ee677519c17db27e639) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24)
> (88ef2e009895f1fcd4bf93fc05eb88bd) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24)
> (375968643fd929aac19c5a9ef85738d3) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (19/24) (9d263d3b7ebb7a9d316ac075c20a7fba)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24)
> (88c63f793aa4348764a4ad3f949fdfc9) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,111 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24)
> (acd3dbc304ddf6184721c8c24d1027d4) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,112 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24)
> (07147b57eb7a0aa75434b0c1253dc7a0) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,112 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (18/24) (24972489627b0e1b261fd6ee183b47cc)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,112 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (9/24) (ccf24c53e3188fe92acd480af49b2fb5)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,116 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (13/24) (ebb5d517f966f535241dac389dcffec3)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,118 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (14/24) (22e6571c51c1292dcf78597b3f7eed0c)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,119 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (17/24) (2600fedee2b14a309e9a81761fcc4a59)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,120 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (24/24) (41fb0267c6a18256b770ade5a5fbde3e)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,120 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (18/24) (ba6831817b3b7aeb918e67416f01a5aa)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,121 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (5/24) (e0f380d9e90c44591056f7bd9bc1d2a3)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,121 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24)
> (6a232b503d9d21a6ad069d2760115616) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,121 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (21/24) (6837f134eb74536e5092de110689c5ce)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,121 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24)
> (f5cde73e13011e459ed8fb67ec7c6936) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,121 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24)
> (2759f49abeeaea4795f6b51d07fe7948) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,121 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24)
> (b04e4010ea3f9836b5173c5c904a54d6) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,122 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (2/24) (63ada3e9d24c6582324778b65330268c)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,122 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24)
> (2a6fde4972073924fea473a9e4f351d8) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,122 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24)
> (925a32f2d260c91debb211a9e4bdd950) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,122 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24)
> (902d697b6196fb4fb4e42dc3e10dff2e) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,122 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (15/24) (94bd1b1f69f72971a9c7c551b5f0f61c)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,122 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24)
> (257e6c5fb4c8b5465958508aa74fbf26) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,123 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (8/24) (5ba4294fcaa08e972a46bb2abd75dde3)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,123 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (22/24) (59a00091f4d063e6bc9c809e54afa1d3)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,125 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (10/24) (59573a3d480f4c4c25dbd553edef7eff)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,125 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (1/24) (b56ad1de01fd610a21448aa6d904137a)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,127 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (1/24) (e4e860b6be3f4f364266cbd3af20a154)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,127 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (19/24) (e1b21f03b7dba0fccca778e1a7d1519b)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,128 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24)
> (02dabd198974c85617c18fb271ef1ea7) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,128 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24)
> (d932b2c9eeaf8a28d12630c51aa61ff5) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,128 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24)
> (3b71c9111769678b9fcd55ab15778eb2) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,128 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (9/24) (edfbc825731b434f904f06098c129dfe)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (6/24) (42156a2c610fe455c27e50e377816ffa)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (12/24) (05bcd51f35ceb57292bffaf57ff424f5)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,128 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (16/24) (ca54cee421ddb67962a369cafa9d532a)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24)
> (90a713fd5dbccb33cf9c909c059feb69) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24)
> (ba9628f18848bc12c58a6b2ad1421550) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24)
> (07b1043609b0f37476b7af581d27182f) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24)
> (e003ab4b29181900820dd4c78bba5b42) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24)
> (1946356177df8086e4514ffd811f9309) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24)
> (6128fa7b3629ae4f712e188d677dc3ba) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,129 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24)
> (2cd85be968f6a8b7ec00b57319b22075) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,130 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24)
> (b46d81f3850846d334af4498e2971596) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,130 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24)
> (3e68a564f9292dda58bad464e9fb2605) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,130 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (23/24) (925f74401292ce293caadbac4e353efb)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,130 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24)
> (fc140c374ab270c3907143ac04a62419) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,131 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24)
> (bb39943f87c2543545cbf6fe4c51868b) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,131 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24)
> (0995c67b6fc9dee9f4d37d5794a5550c) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,132 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (24/24)
> (c03b0183ee6939a90e54719f8c857223) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,132 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (4/24) (c48870a8cc3460ed0052281b1a3ff964)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,132 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (22/24) (7ca8b68a6478f6774b6141cd4154d053)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,133 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (20/24) (83b7d36a7bd0960772532bcdceaf5e88)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,133 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (3/24) (1b2a99a4efc52201d20a4c678938f3d4)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,137 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (17/24) (d97b945c9fe5add0301aed02fcb58646)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,139 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (2/24) (bc2176debe67db69e54403e4fe70e7d6)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,140 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (7/24) (51efcc87dde178b498fd6e07b75b88a2)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,140 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (21/24) (88d5ba9698387989f27f7c68c5539cf6)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,144 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (16/24) (3b2a57dfc9dbfe2210f95c32cec33af2)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,146 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (24/24) (46579e2315960422d172cb33c426f920)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,156 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (8/24) (ed980803b091e73687dd0be751354f69)
> switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,160 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24)
> (1bcf1913643f83879b8eb94588898813) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24)
> (02cbc25dece24970d1e87b9549499834) switched from CANCELING to CANCELED
> 2016-11-03 13:42:47,297 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24)
> (4f40190f5340b685c1e43c57e462a745) switched from CANCELING to CANCELED
> 2016-11-03 13:42:48,223 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24)
> (66a59bc422fb3132ab7747e04b36d064) switched from CANCELING to CANCELED
> 2016-11-03 13:42:48,223 INFO
> org.apache.flink.runtime.executiongraph.restart.ExecutionGraphRestarter  -
> Delaying retry of job execution for 10000 ms ...
> 2016-11-03 13:42:48,223 INFO  org.apache.flink.yarn.YarnJobManager
>                   - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09
> (Prod_Query_Engine) changed to RESTARTING.
> 2016-11-03 13:42:58,224 INFO  org.apache.flink.yarn.YarnJobManager
>                   - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09
> (Prod_Query_Engine) changed to CREATED.
> 2016-11-03 13:42:58,224 INFO  org.apache.flink.yarn.YarnJobManager
>                   - Status of job 597b4f8d8fc825cfbfaba9419cbb7e09
> (Prod_Query_Engine) changed to RUNNING.
> 2016-11-03 13:42:58,224 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24)
> (8a477f7a9f26ae73f92a45a5692939cd) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,224 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24)
> (8a477f7a9f26ae73f92a45a5692939cd) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24) (attempt
> #10) to cldnode08
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24)
> (2b99eb238bd3e8612dd1dc2393ac5428) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24)
> (2b99eb238bd3e8612dd1dc2393ac5428) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (2/24) (attempt
> #10) to cldnode06
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24)
> (0d1559814918cb456c304ccf3030b0f7) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24)
> (0d1559814918cb456c304ccf3030b0f7) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (3/24) (attempt
> #10) to cldnode03
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24)
> (910271b03af991b3427cd1100f99a064) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24)
> (910271b03af991b3427cd1100f99a064) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (4/24) (attempt
> #10) to cldnode07
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24)
> (b39571fd91ad48de7f2f7d3600350404) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24)
> (b39571fd91ad48de7f2f7d3600350404) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,225 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (5/24) (attempt
> #10) to cldnode04
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24)
> (c9a12b9d6be6b43b59bf854164051515) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24)
> (c9a12b9d6be6b43b59bf854164051515) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (6/24) (attempt
> #10) to cldnode05
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24)
> (84d185938655476323407afc3be9cb07) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24)
> (84d185938655476323407afc3be9cb07) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (7/24) (attempt
> #10) to cldnode08
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24)
> (e016baf5af215a3d524cd9513d1ba63d) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24)
> (e016baf5af215a3d524cd9513d1ba63d) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (8/24) (attempt
> #10) to cldnode06
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24)
> (7bc9c8563ab4fb5c55bd70d7c541e314) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24)
> (7bc9c8563ab4fb5c55bd70d7c541e314) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (9/24) (attempt
> #10) to cldnode03
> 2016-11-03 13:42:58,226 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24)
> (fca5bc78f05504a5199289afed8a5923) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24)
> (fca5bc78f05504a5199289afed8a5923) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (10/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24)
> (6a38e04d57245634ba6cce91a6c98ac4) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24)
> (6a38e04d57245634ba6cce91a6c98ac4) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (11/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24)
> (bc2bea1a21655b7f03415522840da8d3) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24)
> (bc2bea1a21655b7f03415522840da8d3) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (12/24)
> (attempt #10) to cldnode05
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24)
> (a0ecaff73a6c3ebc0fd557887e778eb5) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24)
> (a0ecaff73a6c3ebc0fd557887e778eb5) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (13/24)
> (attempt #10) to cldnode08
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24)
> (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24)
> (9f2d0d7de5f66e80b243733ea8d8fa9c) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,227 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (14/24)
> (attempt #10) to cldnode06
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24)
> (8d7df0c283c259a8fb95812d1bc78608) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24)
> (8d7df0c283c259a8fb95812d1bc78608) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (15/24)
> (attempt #10) to cldnode03
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24)
> (b359c281228c857cd49b5af1bfc82290) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24)
> (b359c281228c857cd49b5af1bfc82290) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (16/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24)
> (ec709d95b8456210cdd821846b2f1ee2) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24)
> (ec709d95b8456210cdd821846b2f1ee2) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (17/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24)
> (bd3c09b0d4a580ede8e4d8fab88cf807) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24)
> (bd3c09b0d4a580ede8e4d8fab88cf807) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (18/24)
> (attempt #10) to cldnode05
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24)
> (46072d491d7c11f1e4406da939407aeb) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24)
> (46072d491d7c11f1e4406da939407aeb) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,228 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (19/24)
> (attempt #10) to cldnode08
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24)
> (72f3aad0236dca73a172766d2a4afa1c) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24)
> (72f3aad0236dca73a172766d2a4afa1c) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (20/24)
> (attempt #10) to cldnode06
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24)
> (2b529d27d0989aaa45e74847900b9bd2) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24)
> (2b529d27d0989aaa45e74847900b9bd2) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (21/24)
> (attempt #10) to cldnode03
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24)
> (cc2c67552af2d54e3e412f2fd453042e) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24)
> (cc2c67552af2d54e3e412f2fd453042e) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (22/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24)
> (10494b739882ad7feb43e0247190dfc6) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24)
> (10494b739882ad7feb43e0247190dfc6) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (23/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24)
> (06b7fceb9df52ee6643c788061f11261) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,229 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24)
> (06b7fceb9df52ee6643c788061f11261) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> (Flat Map -> Map, Flat Map -> Map) (24/24)
> (attempt #10) to cldnode05
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24)
> (aeeea1e1eeea141ae6199e927a568dfe) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24)
> (aeeea1e1eeea141ae6199e927a568dfe) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (1/24)
> (attempt #10) to cldnode08
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24)
> (c275f7f1fcbc1f448d8c976c5b7e161b) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24)
> (c275f7f1fcbc1f448d8c976c5b7e161b) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (2/24)
> (attempt #10) to cldnode08
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24)
> (96d5901b42e3d90546c565fa87737333) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24)
> (96d5901b42e3d90546c565fa87737333) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (3/24)
> (attempt #10) to cldnode08
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24)
> (827355f9c98cd9962be947578327da87) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24)
> (827355f9c98cd9962be947578327da87) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (4/24)
> (attempt #10) to cldnode08
> 2016-11-03 13:42:58,230 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24)
> (eb87d63985d400312d84205dd3a08e21) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24)
> (eb87d63985d400312d84205dd3a08e21) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (5/24)
> (attempt #10) to cldnode06
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24)
> (f46bf849d5a73caffb2ab07b7820f915) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24)
> (f46bf849d5a73caffb2ab07b7820f915) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (6/24)
> (attempt #10) to cldnode06
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24)
> (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24)
> (5b9c1f50a9a5cf71ef8c9dcb1f23cc0a) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (7/24)
> (attempt #10) to cldnode06
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24)
> (9b17e65e7bea2384cf92ae625f2addf8) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24)
> (9b17e65e7bea2384cf92ae625f2addf8) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (8/24)
> (attempt #10) to cldnode06
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24)
> (0984ebe3d594a7009916c2e95ea5d532) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24)
> (0984ebe3d594a7009916c2e95ea5d532) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (9/24)
> (attempt #10) to cldnode03
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24)
> (daee6064608145b06088666b7babdca7) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,231 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24)
> (daee6064608145b06088666b7babdca7) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (10/24)
> (attempt #10) to cldnode03
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24)
> (76624c6abd0769f75eaa07711d44e964) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24)
> (76624c6abd0769f75eaa07711d44e964) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (11/24)
> (attempt #10) to cldnode03
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24)
> (f448c1bf173ea7f12dc02e4b18c3545c) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24)
> (f448c1bf173ea7f12dc02e4b18c3545c) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (12/24)
> (attempt #10) to cldnode03
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24)
> (7e606bd4b24076d8c14d44b03676cc6b) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24)
> (7e606bd4b24076d8c14d44b03676cc6b) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (13/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24)
> (290f3384e4819ca8a209c288de0de498) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24)
> (290f3384e4819ca8a209c288de0de498) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (14/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24)
> (1d6ce9ffc4e430064271d408cc8bc29a) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,232 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24)
> (1d6ce9ffc4e430064271d408cc8bc29a) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (15/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24)
> (27592f00a6cd545d043eccffb00bb19d) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24)
> (27592f00a6cd545d043eccffb00bb19d) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (16/24)
> (attempt #10) to cldnode07
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24)
> (024d06427a98144a85b3fd7168e49d45) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24)
> (024d06427a98144a85b3fd7168e49d45) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (17/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24)
> (d5abd030d970fe399c0bbb60885ab8f2) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24)
> (d5abd030d970fe399c0bbb60885ab8f2) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (18/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24)
> (ed5e99e3763c6750a7cab5f1032dd746) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24)
> (ed5e99e3763c6750a7cab5f1032dd746) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (19/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24)
> (c8bff8478ae3788bad8ce5af463735e3) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,233 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24)
> (c8bff8478ae3788bad8ce5af463735e3) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (20/24)
> (attempt #10) to cldnode04
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24)
> (778de29fb0826a276340ae284531c179) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24)
> (778de29fb0826a276340ae284531c179) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (21/24)
> (attempt #10) to cldnode05
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24)
> (fdfa402e13b4914493fa04c153f415ff) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24)
> (fdfa402e13b4914493fa04c153f415ff) switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (1/24) (9882efa4e42ab981527f5111f80692ff)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Source: Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (22/24)
> (attempt #10) to cldnode05
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (2/24) (c60a887f493cf6e95a78dfb4e7375c46)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (1/24) (9882efa4e42ab981527f5111f80692ff)
> switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (3/24) (4bf8a429fc44579751cbe964ffcfbaa0)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (12/24) (d426f245f247e09e292353675f213d28)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (16/24) (7aae31976d48d69f1e77ad54e4aa93b1)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (21/24) (db8e88b7ce833f5a3652ee7ecb285103)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (10/24) (84a67e77b96e81c59a5af0cf41c8bbea)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,235 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (20/24) (7e8fce0aa62eb2279a8b228aa8f2d375)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Map -> Flat Map -> Map -> Sink: Unnamed (1/24) (attempt #10) to cldnode04
> 2016-11-03 13:42:58,235 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (23/24) (4b75e618f2de1b527863250a918c6b7e)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (2/24) (c60a887f493cf6e95a78dfb4e7375c46)
> switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,236 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (23/24) (4b75e618f2de1b527863250a918c6b7e)
> switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,237 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (24/24) (82e7e8883e9d32b7f71022f4e1fe925e)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> (Flat Map -> Map, Flat Map -> Map) (1/24)
> (8a477f7a9f26ae73f92a45a5692939cd) switched from DEPLOYING to RUNNING
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (9/24) (6acf1ab559e8582dc60a54b4b37d6728)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (7/24) (f3641e77026ce337dd7b75eaad5841c2)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (8/24) (01d8a2749f51e2e30bafaa12724ff631)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source:
> Custom Source -> Flat Map -> (Map -> Map, Map -> Map) (23/24)
> (254a1d29bae123c554d0b0c5c113bf3f) switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (4/24) (0dfd37bdb6a1b26d519a7beac04a1164)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (6/24) (9c3bf96bf0595a898ba2ea8b58af2092)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,237 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (4/24) (0dfd37bdb6a1b26d519a7beac04a1164)
> switched from SCHEDULED to DEPLOYING
> 2016-11-03 13:42:58,234 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Map -> Flat
> Map -> Map -> Sink: Unnamed (5/24) (81693344e2c2a9a8ca92e9ad4da9dc11)
> switched from CREATED to SCHEDULED
> 2016-11-03 13:42:58,238 INFO
> org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying
> Map -> Flat Map -> Map -> Sink: Unnamed (4/24) (attempt #10) t