th, Torben
Cc: user@flink.apache.org
Betreff: Re: Pyflink Join with versioned view / table
Hi, Torben
Happy to hear you address your problem, the first option can resolve the
situation that partial partitions of the Kafka topic did not receive data, but
if all partitions didn't receive data
Hi, Torben
Happy to hear you address your problem, the first option can resolve the
situation that partial partitions of the Kafka topic did not receive data,
but if all partitions didn’t receive data, the watermark won’t be pushed
forward, and the temporal join won’t be triggered.
Otherwise,
now. This seems to work for
me right now but could result in problems in the future.
Best
Torben
Von: Leonard Xu [mailto:xbjt...@gmail.com]
Gesendet: Samstag, 16. Januar 2021 15:05
An: Barth, Torben
Cc: user@flink.apache.org
Betreff: Re: Pyflink Join with versioned view / table
Hi, Torben
When
Hi, Torben
> When implementing the join I get only updates when the right table changes
The event-time temporal join versioned table is triggered watermark which
calculated by both left and right table’s watermark, so you get only updated
when the right table changes(which is the slower one in
Dear List,
I have trouble implementing a join between two streaming tables in Python Table
API.
The left table of my join should be enriched with the information with the last
value of the right_table. The right_table is updated only rarely (maybe after
15 minutes). When implementing the join
