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