[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Running Flink on Yarn

If you mean time-windowed join documented here [1].
I think it implicitly uses keyed stream [2] where the key is the field in equi-join predicate.
The window state is also keyed [3] in this case.
I also cc Timo and Piotr, they might add more to this topic.

[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql.html#joins
[2] https://github.com/apache/flink/blob/8674b69964eae50cad024f2c5caf92a71bf21a09/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala#L261
[3] https://github.com/apache/flink/blob/c8b2ee27d80b1437dd65a9327da65c251febd736/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/TimeBoundedStreamJoin.scala#L78

On Mon, Dec 24, 2018 at 6:29 PM Anil <anilsingh.jsr@xxxxxxxxx> wrote:
Thanks for the quick response Andrey. I'm doing a SQL time-windowed join on
non-keyed stream.
So all the thread in various task slot in the same TM will share this state.

Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/