Status of Kafka011JsonTableSink for 1.4.0 release?

Hello, I'm new to Flink and I'd like to use it along with Kafka 0.11, to do some processing on a stream of JSON data. I've been looking the docs of the Table API (and the relevant GitHub code), and I see that recently there was a Kafka011JsonTableSource submitted, which will be available in the F

Apache Flink - Non equi joins

Hi: Is it possible to perform non-equi joins in Flink using the core or relational apis ?  Is there any documentation on what sort of joins are supported with their examples ? Thanks Mans

Re: Apache Flink - Question about TriggerResult.FIRE

Hi: Another question - what happens if the trigger never calls PURGE or FIRE_AND_PURGE and only calls FIRE ?  Are the window and it's contents removed after the end time + lateness are exceeded ? Thanks On Monday, November 20, 2017 2:18 AM, Stefan Richter wrote: Hi, "In the first ca