Hi, Amr
What sink do you use? I think it means that the sink does not support the
"upsert".
If you use Kafka as a sink[1] I think you could choose to try it after 1.12.
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connectors/upsert-kafka.html
Best,
Guowei
On Mon, Dec 7, 2
Hello,
I am newbie in Flink, I am stuck and looking for help, I want to join
Streams A, B, C, D from csv source files, some of the streams update
frequently and I have another stream high throughput from Kafka K and I need
to filter K stream from [A,B,C,D]. I tried using Flink table API, Union a
