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
