flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <zhenhao...@accenture.com>
Subject RocksDB IO error
Date Thu, 10 Nov 2016 13:22:25 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message