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 all streams [A,B,C,D] and then execute query SELECT * FROM K k WHERE k.key Not IN (SELECT Key FROM ALL_UNION_LIST) but stuck in Error AppendStreamTableSink doesn't consuming update and delete. Only select query without join get executed and if you can let me know also How I can implement this solution in DataStream API. All the streams have common key.
Best, Amr -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
