You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by zh...@accenture.com on 2016/11/10 13:22:25 UTC
RocksDB IO error
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
Re: RocksDB IO error
Posted by Aljoscha Krettek <al...@apache.org>.
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 <zh...@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