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,

CoProcessFunction doesn't support timer on keyed stream

2018-04-25 Thread Ken Krugler
Hi devs, I’m using Flink 1.5-SNAPSHOT, and I’ve got a connected stream that I’m using with a CoProcessFunction. One of the streams is keyed, and the other is broadcast. As per the documentation (https://ci.apache.org/projects/flink/flink-docs-release-1.4/api/java/org/apache/flink/streaming/api