log4j:WARN No appenders could be found for logger (org.apache.kafka.clients.consumer.ConsumerConfig).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
09/28/2016 22:56:12	Job execution switched to status RUNNING.
09/28/2016 22:56:12	Source: Custom Source -> Map(1/1) switched to SCHEDULED 
09/28/2016 22:56:13	Source: Custom Source -> Map(1/1) switched to DEPLOYING 
09/28/2016 22:56:13	Map -> Sink: Unnamed(1/1) switched to SCHEDULED 
09/28/2016 22:56:13	Map -> Sink: Unnamed(1/1) switched to DEPLOYING 
09/28/2016 22:56:13	Map -> Sink: Unnamed(1/1) switched to RUNNING 
09/28/2016 22:56:13	Source: Custom Source -> Map(1/1) switched to RUNNING 
open() called
Previous message is  current message is message0
message MESSAGE0MESSAGE0 state: default non state default
Previous message is MESSAGE0 current message is message1
message MESSAGE1MESSAGE1 state: MESSAGE0MESSAGE0 non state MESSAGE0MESSAGE0
Previous message is MESSAGE1 current message is message2
message MESSAGE2MESSAGE2 state: MESSAGE1MESSAGE1 non state MESSAGE1MESSAGE1
Previous message is MESSAGE2 current message is message3
message MESSAGE3MESSAGE3 state: MESSAGE2MESSAGE2 non state MESSAGE2MESSAGE2
Previous message is MESSAGE3 current message is message4
message MESSAGE4MESSAGE4 state: MESSAGE3MESSAGE3 non state MESSAGE3MESSAGE3
Previous message is MESSAGE4 current message is message5
message MESSAGE5MESSAGE5 state: MESSAGE4MESSAGE4 non state MESSAGE4MESSAGE4
Previous message is MESSAGE5 current message is message6
message MESSAGE6MESSAGE6 state: MESSAGE5MESSAGE5 non state MESSAGE5MESSAGE5
Previous message is MESSAGE6 current message is message7
message MESSAGE7MESSAGE7 state: MESSAGE6MESSAGE6 non state MESSAGE6MESSAGE6
Previous message is MESSAGE7 current message is message8
message MESSAGE8MESSAGE8 state: MESSAGE7MESSAGE7 non state MESSAGE7MESSAGE7
Previous message is MESSAGE8 current message is message9
message MESSAGE9MESSAGE9 state: MESSAGE8MESSAGE8 non state MESSAGE8MESSAGE8
Previous message is MESSAGE9 current message is message10
message MESSAGE10MESSAGE10 state: MESSAGE9MESSAGE9 non state MESSAGE9MESSAGE9
Previous message is MESSAGE10 current message is message11
message MESSAGE11MESSAGE11 state: MESSAGE10MESSAGE10 non state MESSAGE10MESSAGE10
Previous message is MESSAGE11 current message is message12
message MESSAGE12MESSAGE12 state: MESSAGE11MESSAGE11 non state MESSAGE11MESSAGE11
Previous message is MESSAGE12 current message is message13
message MESSAGE13MESSAGE13 state: MESSAGE12MESSAGE12 non state MESSAGE12MESSAGE12
Previous message is MESSAGE13 current message is message14
message MESSAGE14MESSAGE14 state: MESSAGE13MESSAGE13 non state MESSAGE13MESSAGE13
Previous message is MESSAGE14 current message is message15
message MESSAGE15MESSAGE15 state: MESSAGE14MESSAGE14 non state MESSAGE14MESSAGE14
Previous message is MESSAGE15 current message is message16
message MESSAGE16MESSAGE16 state: MESSAGE15MESSAGE15 non state MESSAGE15MESSAGE15
Previous message is MESSAGE16 current message is message17
message MESSAGE17MESSAGE17 state: MESSAGE16MESSAGE16 non state MESSAGE16MESSAGE16
Previous message is MESSAGE17 current message is message18
message MESSAGE18MESSAGE18 state: MESSAGE17MESSAGE17 non state MESSAGE17MESSAGE17
Previous message is MESSAGE18 current message is message19
message MESSAGE19MESSAGE19 state: MESSAGE18MESSAGE18 non state MESSAGE18MESSAGE18
Previous message is MESSAGE19 current message is message20
message MESSAGE20MESSAGE20 state: MESSAGE19MESSAGE19 non state MESSAGE19MESSAGE19
Previous message is MESSAGE20 current message is message21
message MESSAGE21MESSAGE21 state: MESSAGE20MESSAGE20 non state MESSAGE20MESSAGE20
Previous message is MESSAGE21 current message is message22
message MESSAGE22MESSAGE22 state: MESSAGE21MESSAGE21 non state MESSAGE21MESSAGE21
Previous message is MESSAGE22 current message is message23
message MESSAGE23MESSAGE23 state: MESSAGE22MESSAGE22 non state MESSAGE22MESSAGE22
Previous message is MESSAGE23 current message is message24
message MESSAGE24MESSAGE24 state: MESSAGE23MESSAGE23 non state MESSAGE23MESSAGE23
Previous message is MESSAGE24 current message is message25
message MESSAGE25MESSAGE25 state: MESSAGE24MESSAGE24 non state MESSAGE24MESSAGE24
Previous message is MESSAGE25 current message is message26
message MESSAGE26MESSAGE26 state: MESSAGE25MESSAGE25 non state MESSAGE25MESSAGE25
Previous message is MESSAGE26 current message is message27
message MESSAGE27MESSAGE27 state: MESSAGE26MESSAGE26 non state MESSAGE26MESSAGE26
Previous message is MESSAGE27 current message is message28
message MESSAGE28MESSAGE28 state: MESSAGE27MESSAGE27 non state MESSAGE27MESSAGE27
Previous message is MESSAGE28 current message is message29
message MESSAGE29MESSAGE29 state: MESSAGE28MESSAGE28 non state MESSAGE28MESSAGE28
Previous message is MESSAGE29 current message is message30
message MESSAGE30MESSAGE30 state: MESSAGE29MESSAGE29 non state MESSAGE29MESSAGE29
Previous message is MESSAGE30 current message is message31
message MESSAGE31MESSAGE31 state: MESSAGE30MESSAGE30 non state MESSAGE30MESSAGE30
Previous message is MESSAGE31 current message is message32
message MESSAGE32MESSAGE32 state: MESSAGE31MESSAGE31 non state MESSAGE31MESSAGE31
Previous message is MESSAGE32 current message is message33
message MESSAGE33MESSAGE33 state: MESSAGE32MESSAGE32 non state MESSAGE32MESSAGE32
Previous message is MESSAGE33 current message is message34
message MESSAGE34MESSAGE34 state: MESSAGE33MESSAGE33 non state MESSAGE33MESSAGE33
Previous message is MESSAGE34 current message is message35
message MESSAGE35MESSAGE35 state: MESSAGE34MESSAGE34 non state MESSAGE34MESSAGE34
Previous message is MESSAGE35 current message is message36
message MESSAGE36MESSAGE36 state: MESSAGE35MESSAGE35 non state MESSAGE35MESSAGE35
Previous message is MESSAGE36 current message is message37
message MESSAGE37MESSAGE37 state: MESSAGE36MESSAGE36 non state MESSAGE36MESSAGE36
Previous message is MESSAGE37 current message is message38
message MESSAGE38MESSAGE38 state: MESSAGE37MESSAGE37 non state MESSAGE37MESSAGE37
Previous message is MESSAGE38 current message is message39
message MESSAGE39MESSAGE39 state: MESSAGE38MESSAGE38 non state MESSAGE38MESSAGE38
Previous message is MESSAGE39 current message is message40
message MESSAGE40MESSAGE40 state: MESSAGE39MESSAGE39 non state MESSAGE39MESSAGE39
Previous message is MESSAGE40 current message is message41
message MESSAGE41MESSAGE41 state: MESSAGE40MESSAGE40 non state MESSAGE40MESSAGE40
Previous message is MESSAGE41 current message is message42
message MESSAGE42MESSAGE42 state: MESSAGE41MESSAGE41 non state MESSAGE41MESSAGE41
Previous message is MESSAGE42 current message is message43
message MESSAGE43MESSAGE43 state: MESSAGE42MESSAGE42 non state MESSAGE42MESSAGE42
Previous message is MESSAGE43 current message is message44
message MESSAGE44MESSAGE44 state: MESSAGE43MESSAGE43 non state MESSAGE43MESSAGE43
Previous message is MESSAGE44 current message is message45
message MESSAGE45MESSAGE45 state: MESSAGE44MESSAGE44 non state MESSAGE44MESSAGE44
Previous message is MESSAGE45 current message is message46
message MESSAGE46MESSAGE46 state: MESSAGE45MESSAGE45 non state MESSAGE45MESSAGE45
Previous message is MESSAGE46 current message is message47
message MESSAGE47MESSAGE47 state: MESSAGE46MESSAGE46 non state MESSAGE46MESSAGE46
Previous message is MESSAGE47 current message is message48
message MESSAGE48MESSAGE48 state: MESSAGE47MESSAGE47 non state MESSAGE47MESSAGE47
Previous message is MESSAGE48 current message is message49
message MESSAGE49MESSAGE49 state: MESSAGE48MESSAGE48 non state MESSAGE48MESSAGE48
Previous message is MESSAGE49 current message is message50
message MESSAGE50MESSAGE50 state: MESSAGE49MESSAGE49 non state MESSAGE49MESSAGE49
Previous message is MESSAGE50 current message is message51
message MESSAGE51MESSAGE51 state: MESSAGE50MESSAGE50 non state MESSAGE50MESSAGE50
Previous message is MESSAGE51 current message is message52
message MESSAGE52MESSAGE52 state: MESSAGE51MESSAGE51 non state MESSAGE51MESSAGE51
Previous message is MESSAGE52 current message is message53
message MESSAGE53MESSAGE53 state: MESSAGE52MESSAGE52 non state MESSAGE52MESSAGE52
Previous message is MESSAGE53 current message is message54
message MESSAGE54MESSAGE54 state: MESSAGE53MESSAGE53 non state MESSAGE53MESSAGE53
Previous message is MESSAGE54 current message is message55
message MESSAGE55MESSAGE55 state: MESSAGE54MESSAGE54 non state MESSAGE54MESSAGE54
Previous message is MESSAGE55 current message is message56
message MESSAGE56MESSAGE56 state: MESSAGE55MESSAGE55 non state MESSAGE55MESSAGE55
Previous message is MESSAGE56 current message is message57
message MESSAGE57MESSAGE57 state: MESSAGE56MESSAGE56 non state MESSAGE56MESSAGE56
Previous message is MESSAGE57 current message is message58
message MESSAGE58MESSAGE58 state: MESSAGE57MESSAGE57 non state MESSAGE57MESSAGE57
Previous message is MESSAGE58 current message is message59
message MESSAGE59MESSAGE59 state: MESSAGE58MESSAGE58 non state MESSAGE58MESSAGE58
close() called
09/28/2016 22:56:14	Map -> Sink: Unnamed(1/1) switched to FAILED 
java.lang.RuntimeException: Could not forward element to next operator
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:358)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:346)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:329)
	at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39)
	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:176)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66)
	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:722)
Caused by: com.demo.flink.failover.MyException: Sink Failed Intentionally
	at com.demo.flink.failover.Sink.invoke(Sink.java:20)
	at com.demo.flink.failover.Sink.invoke(Sink.java:1)
	at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:373)
	... 9 more

09/28/2016 22:56:14	Job execution switched to status FAILING.
java.lang.RuntimeException: Could not forward element to next operator
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:358)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:346)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:329)
	at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39)
	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:176)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66)
	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:722)
Caused by: com.demo.flink.failover.MyException: Sink Failed Intentionally
	at com.demo.flink.failover.Sink.invoke(Sink.java:20)
	at com.demo.flink.failover.Sink.invoke(Sink.java:1)
	at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:373)
	... 9 more
09/28/2016 22:56:14	Source: Custom Source -> Map(1/1) switched to CANCELING 
09/28/2016 22:56:14	Source: Custom Source -> Map(1/1) switched to CANCELED 
09/28/2016 22:56:14	Job execution switched to status RESTARTING.
09/28/2016 22:56:24	Job execution switched to status CREATED.
09/28/2016 22:56:24	Job execution switched to status RUNNING.
09/28/2016 22:56:24	Source: Custom Source -> Map(1/1) switched to SCHEDULED 
09/28/2016 22:56:24	Source: Custom Source -> Map(1/1) switched to DEPLOYING 
09/28/2016 22:56:24	Map -> Sink: Unnamed(1/1) switched to SCHEDULED 
09/28/2016 22:56:24	Map -> Sink: Unnamed(1/1) switched to DEPLOYING 
09/28/2016 22:56:24	Source: Custom Source -> Map(1/1) switched to RUNNING 
09/28/2016 22:56:24	Map -> Sink: Unnamed(1/1) switched to RUNNING 
open() called
Previous message is  current message is message0
message MESSAGE0MESSAGE0 state: default non state default
Previous message is MESSAGE0 current message is message1
message MESSAGE1MESSAGE1 state: MESSAGE0MESSAGE0 non state MESSAGE0MESSAGE0
Previous message is MESSAGE1 current message is message2
message MESSAGE2MESSAGE2 state: MESSAGE1MESSAGE1 non state MESSAGE1MESSAGE1
Previous message is MESSAGE2 current message is message3
message MESSAGE3MESSAGE3 state: MESSAGE2MESSAGE2 non state MESSAGE2MESSAGE2
Previous message is MESSAGE3 current message is message4
message MESSAGE4MESSAGE4 state: MESSAGE3MESSAGE3 non state MESSAGE3MESSAGE3
Previous message is MESSAGE4 current message is message5
message MESSAGE5MESSAGE5 state: MESSAGE4MESSAGE4 non state MESSAGE4MESSAGE4
Previous message is MESSAGE5 current message is message6
message MESSAGE6MESSAGE6 state: MESSAGE5MESSAGE5 non state MESSAGE5MESSAGE5
Previous message is MESSAGE6 current message is message7
message MESSAGE7MESSAGE7 state: MESSAGE6MESSAGE6 non state MESSAGE6MESSAGE6
Previous message is MESSAGE7 current message is message8
message MESSAGE8MESSAGE8 state: MESSAGE7MESSAGE7 non state MESSAGE7MESSAGE7
Previous message is MESSAGE8 current message is message9
message MESSAGE9MESSAGE9 state: MESSAGE8MESSAGE8 non state MESSAGE8MESSAGE8
Previous message is MESSAGE9 current message is message10
message MESSAGE10MESSAGE10 state: MESSAGE9MESSAGE9 non state MESSAGE9MESSAGE9
Previous message is MESSAGE10 current message is message11
message MESSAGE11MESSAGE11 state: MESSAGE10MESSAGE10 non state MESSAGE10MESSAGE10
Previous message is MESSAGE11 current message is message12
message MESSAGE12MESSAGE12 state: MESSAGE11MESSAGE11 non state MESSAGE11MESSAGE11
Previous message is MESSAGE12 current message is message13
message MESSAGE13MESSAGE13 state: MESSAGE12MESSAGE12 non state MESSAGE12MESSAGE12
Previous message is MESSAGE13 current message is message14
message MESSAGE14MESSAGE14 state: MESSAGE13MESSAGE13 non state MESSAGE13MESSAGE13
Previous message is MESSAGE14 current message is message15
message MESSAGE15MESSAGE15 state: MESSAGE14MESSAGE14 non state MESSAGE14MESSAGE14
Previous message is MESSAGE15 current message is message16
message MESSAGE16MESSAGE16 state: MESSAGE15MESSAGE15 non state MESSAGE15MESSAGE15
Previous message is MESSAGE16 current message is message17
message MESSAGE17MESSAGE17 state: MESSAGE16MESSAGE16 non state MESSAGE16MESSAGE16
Previous message is MESSAGE17 current message is message18
message MESSAGE18MESSAGE18 state: MESSAGE17MESSAGE17 non state MESSAGE17MESSAGE17
Previous message is MESSAGE18 current message is message19
message MESSAGE19MESSAGE19 state: MESSAGE18MESSAGE18 non state MESSAGE18MESSAGE18
Previous message is MESSAGE19 current message is message20
message MESSAGE20MESSAGE20 state: MESSAGE19MESSAGE19 non state MESSAGE19MESSAGE19
Previous message is MESSAGE20 current message is message21
message MESSAGE21MESSAGE21 state: MESSAGE20MESSAGE20 non state MESSAGE20MESSAGE20
Previous message is MESSAGE21 current message is message22
message MESSAGE22MESSAGE22 state: MESSAGE21MESSAGE21 non state MESSAGE21MESSAGE21
Previous message is MESSAGE22 current message is message23
message MESSAGE23MESSAGE23 state: MESSAGE22MESSAGE22 non state MESSAGE22MESSAGE22
Previous message is MESSAGE23 current message is message24
message MESSAGE24MESSAGE24 state: MESSAGE23MESSAGE23 non state MESSAGE23MESSAGE23
Previous message is MESSAGE24 current message is message25
message MESSAGE25MESSAGE25 state: MESSAGE24MESSAGE24 non state MESSAGE24MESSAGE24
Previous message is MESSAGE25 current message is message26
message MESSAGE26MESSAGE26 state: MESSAGE25MESSAGE25 non state MESSAGE25MESSAGE25
Previous message is MESSAGE26 current message is message27
message MESSAGE27MESSAGE27 state: MESSAGE26MESSAGE26 non state MESSAGE26MESSAGE26
Previous message is MESSAGE27 current message is message28
message MESSAGE28MESSAGE28 state: MESSAGE27MESSAGE27 non state MESSAGE27MESSAGE27
Previous message is MESSAGE28 current message is message29
message MESSAGE29MESSAGE29 state: MESSAGE28MESSAGE28 non state MESSAGE28MESSAGE28
Previous message is MESSAGE29 current message is message30
message MESSAGE30MESSAGE30 state: MESSAGE29MESSAGE29 non state MESSAGE29MESSAGE29
Previous message is MESSAGE30 current message is message31
message MESSAGE31MESSAGE31 state: MESSAGE30MESSAGE30 non state MESSAGE30MESSAGE30
Previous message is MESSAGE31 current message is message32
message MESSAGE32MESSAGE32 state: MESSAGE31MESSAGE31 non state MESSAGE31MESSAGE31
Previous message is MESSAGE32 current message is message33
message MESSAGE33MESSAGE33 state: MESSAGE32MESSAGE32 non state MESSAGE32MESSAGE32
Previous message is MESSAGE33 current message is message34
message MESSAGE34MESSAGE34 state: MESSAGE33MESSAGE33 non state MESSAGE33MESSAGE33
Previous message is MESSAGE34 current message is message35
message MESSAGE35MESSAGE35 state: MESSAGE34MESSAGE34 non state MESSAGE34MESSAGE34
Previous message is MESSAGE35 current message is message36
message MESSAGE36MESSAGE36 state: MESSAGE35MESSAGE35 non state MESSAGE35MESSAGE35
Previous message is MESSAGE36 current message is message37
message MESSAGE37MESSAGE37 state: MESSAGE36MESSAGE36 non state MESSAGE36MESSAGE36
Previous message is MESSAGE37 current message is message38
message MESSAGE38MESSAGE38 state: MESSAGE37MESSAGE37 non state MESSAGE37MESSAGE37
Previous message is MESSAGE38 current message is message39
message MESSAGE39MESSAGE39 state: MESSAGE38MESSAGE38 non state MESSAGE38MESSAGE38
Previous message is MESSAGE39 current message is message40
message MESSAGE40MESSAGE40 state: MESSAGE39MESSAGE39 non state MESSAGE39MESSAGE39
Previous message is MESSAGE40 current message is message41
message MESSAGE41MESSAGE41 state: MESSAGE40MESSAGE40 non state MESSAGE40MESSAGE40
Previous message is MESSAGE41 current message is message42
message MESSAGE42MESSAGE42 state: MESSAGE41MESSAGE41 non state MESSAGE41MESSAGE41
Previous message is MESSAGE42 current message is message43
message MESSAGE43MESSAGE43 state: MESSAGE42MESSAGE42 non state MESSAGE42MESSAGE42
Previous message is MESSAGE43 current message is message44
message MESSAGE44MESSAGE44 state: MESSAGE43MESSAGE43 non state MESSAGE43MESSAGE43
Previous message is MESSAGE44 current message is message45
message MESSAGE45MESSAGE45 state: MESSAGE44MESSAGE44 non state MESSAGE44MESSAGE44
Previous message is MESSAGE45 current message is message46
message MESSAGE46MESSAGE46 state: MESSAGE45MESSAGE45 non state MESSAGE45MESSAGE45
Previous message is MESSAGE46 current message is message47
message MESSAGE47MESSAGE47 state: MESSAGE46MESSAGE46 non state MESSAGE46MESSAGE46
Previous message is MESSAGE47 current message is message48
message MESSAGE48MESSAGE48 state: MESSAGE47MESSAGE47 non state MESSAGE47MESSAGE47
Previous message is MESSAGE48 current message is message49
message MESSAGE49MESSAGE49 state: MESSAGE48MESSAGE48 non state MESSAGE48MESSAGE48
Previous message is MESSAGE49 current message is message50
message MESSAGE50MESSAGE50 state: MESSAGE49MESSAGE49 non state MESSAGE49MESSAGE49
Previous message is MESSAGE50 current message is message51
message MESSAGE51MESSAGE51 state: MESSAGE50MESSAGE50 non state MESSAGE50MESSAGE50
Previous message is MESSAGE51 current message is message52
message MESSAGE52MESSAGE52 state: MESSAGE51MESSAGE51 non state MESSAGE51MESSAGE51
Previous message is MESSAGE52 current message is message53
message MESSAGE53MESSAGE53 state: MESSAGE52MESSAGE52 non state MESSAGE52MESSAGE52
Previous message is MESSAGE53 current message is message54
message MESSAGE54MESSAGE54 state: MESSAGE53MESSAGE53 non state MESSAGE53MESSAGE53
Previous message is MESSAGE54 current message is message55
message MESSAGE55MESSAGE55 state: MESSAGE54MESSAGE54 non state MESSAGE54MESSAGE54
Previous message is MESSAGE55 current message is message56
message MESSAGE56MESSAGE56 state: MESSAGE55MESSAGE55 non state MESSAGE55MESSAGE55
Previous message is MESSAGE56 current message is message57
message MESSAGE57MESSAGE57 state: MESSAGE56MESSAGE56 non state MESSAGE56MESSAGE56
Previous message is MESSAGE57 current message is message58
message MESSAGE58MESSAGE58 state: MESSAGE57MESSAGE57 non state MESSAGE57MESSAGE57
Previous message is MESSAGE58 current message is message59
message MESSAGE59MESSAGE59 state: MESSAGE58MESSAGE58 non state MESSAGE58MESSAGE58
close() called
09/28/2016 22:56:26	Map -> Sink: Unnamed(1/1) switched to FAILED 
java.lang.RuntimeException: Could not forward element to next operator
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:358)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:346)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:329)
	at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39)
	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:176)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66)
	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:722)
Caused by: com.demo.flink.failover.MyException: Sink Failed Intentionally
	at com.demo.flink.failover.Sink.invoke(Sink.java:20)
	at com.demo.flink.failover.Sink.invoke(Sink.java:1)
	at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:373)
	... 9 more

09/28/2016 22:56:26	Job execution switched to status FAILING.
java.lang.RuntimeException: Could not forward element to next operator
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:376)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:358)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:346)
	at org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:329)
	at org.apache.flink.streaming.api.operators.StreamMap.processElement(StreamMap.java:39)
	at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:176)
	at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:66)
	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:722)
Caused by: com.demo.flink.failover.MyException: Sink Failed Intentionally
	at com.demo.flink.failover.Sink.invoke(Sink.java:20)
	at com.demo.flink.failover.Sink.invoke(Sink.java:1)
	at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:39)
	at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:373)
	... 9 more
09/28/2016 22:56:26	Source: Custom Source -> Map(1/1) switched to CANCELING 
09/28/2016 22:56:26	Source: Custom Source -> Map(1/1) switched to CANCELED 
09/28/2016 22:56:26	Job execution switched to status RESTARTING.