08/24/2016 08:41:09	Job execution switched to status RUNNING.
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(1/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(1/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(2/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(2/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(3/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(3/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(4/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(4/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(1/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(1/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(2/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(2/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(3/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(3/4) switched to DEPLOYING 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(4/4) switched to SCHEDULED 
08/24/2016 08:41:09	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(4/4) switched to DEPLOYING 
08/24/2016 08:41:09	Timestamps/Watermarks(1/4) switched to SCHEDULED 
08/24/2016 08:41:09	Timestamps/Watermarks(1/4) switched to DEPLOYING 
08/24/2016 08:41:09	Timestamps/Watermarks(2/4) switched to SCHEDULED 
08/24/2016 08:41:09	Timestamps/Watermarks(2/4) switched to DEPLOYING 
08/24/2016 08:41:09	Timestamps/Watermarks(3/4) switched to SCHEDULED 
08/24/2016 08:41:09	Timestamps/Watermarks(3/4) switched to DEPLOYING 
08/24/2016 08:41:09	Timestamps/Watermarks(4/4) switched to SCHEDULED 
08/24/2016 08:41:09	Timestamps/Watermarks(4/4) switched to DEPLOYING 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(1/4) switched to SCHEDULED 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(1/4) switched to DEPLOYING 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(2/4) switched to SCHEDULED 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(2/4) switched to DEPLOYING 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(3/4) switched to SCHEDULED 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(3/4) switched to DEPLOYING 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(4/4) switched to SCHEDULED 
08/24/2016 08:41:09	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(4/4) switched to DEPLOYING 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(1/4) switched to SCHEDULED 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(1/4) switched to DEPLOYING 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(2/4) switched to SCHEDULED 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(2/4) switched to DEPLOYING 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(3/4) switched to SCHEDULED 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(3/4) switched to DEPLOYING 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(4/4) switched to SCHEDULED 
08/24/2016 08:41:09	Flat Map -> Sink: Unnamed(4/4) switched to DEPLOYING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(1/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(3/4) switched to RUNNING 
08/24/2016 08:41:10	Timestamps/Watermarks(1/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(4/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(1/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(2/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(3/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(4/4) switched to RUNNING 
08/24/2016 08:41:10	Source: Custom Source -> Flat Map -> (Sink: Unnamed, Flat Map -> Sink: Unnamed)(2/4) switched to RUNNING 
08/24/2016 08:41:10	Flat Map -> Sink: Unnamed(4/4) switched to RUNNING 
08/24/2016 08:41:10	Flat Map -> Sink: Unnamed(1/4) switched to RUNNING 
08/24/2016 08:41:10	Flat Map -> Sink: Unnamed(3/4) switched to RUNNING 
08/24/2016 08:41:10	Flat Map -> Sink: Unnamed(2/4) switched to RUNNING 
08/24/2016 08:41:10	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(4/4) switched to RUNNING 
08/24/2016 08:41:10	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(3/4) switched to RUNNING 
08/24/2016 08:41:10	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(1/4) switched to RUNNING 
08/24/2016 08:41:10	TriggerWindow(TumblingEventTimeWindows(1000), ListStateDescriptor{name=window-contents, defaultValue=null, serializer=org.apache.flink.api.java.typeutils.runtime.PojoSerializer@ee6042fd}, EventTimeTrigger(), WindowedStream.apply(WindowedStream.java:226)) -> Flat Map -> (Sink: Unnamed, Flat Map -> (Sink: Unnamed, Map -> (Sink: Unnamed, Filter -> Sink: Unnamed)))(2/4) switched to RUNNING 
08/24/2016 08:41:10	Timestamps/Watermarks(4/4) switched to RUNNING 
08/24/2016 08:41:10	Timestamps/Watermarks(2/4) switched to RUNNING 
08/24/2016 08:41:10	Timestamps/Watermarks(3/4) switched to RUNNING