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 <zhenhao...@accenture.com> 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
