Re: CoProcessFunction doesn't support timer on keyed stream

2018-04-26 Thread Kostas Kloudas
Hi again Ken, This is the PR https://github.com/apache/flink/pull/5922 I promised. You can build the docs by going in the docs directory of the Flink repo and executing ./build_docs.sh -p After it finishes, you will be able to see all the doc

Re: CoProcessFunction doesn't support timer on keyed stream

2018-04-26 Thread Kostas Kloudas
Hi Ken, It is true that there is not reason for not having access to the timerService from the processElement of the keyed side. On the other side (the non-keyed side) you cannot set timers because timers are bound to a specific key. Now, if one stream is broadcasted and the other is keyed,