Finally, I did it with union.
Now inside the processElement() function of my CoProcessFunction I am
setting a timer and periodically I want to print out some data through the
Below I attach the image stating the following: "Caused by:
java.lang.UnsupportedOperationException: Setting timers is only supported on
a keyed streams."
My CoProcessFunction is an operator with parallelism=1 (I also use
forceNonParallel()) to make sure about that. Thus, I am not using a Keyed
Is the Keyed State the only way of using Timers?
Furthermore, I must confess that the API is not so clear for the Managed
Operator State, so I am currently NOT implementing any CheckpointedFunction
Is my application going to return the correct results, if I assume no
failures etc etc.?
Thanks in advance.
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/