In order to create table, I use an SQL syntax like val tableEnv = StreamTableEnvironment.create(env, settings) tableEnv.executeSql( "CREATE TABLE asset (smth STRING) " + ...

We are looking to use existing redis streams in our application and process messages using Apache Flick, but could not find Redis source connector ? Any reason why Redis source connector is not availa...

I am working on the Flink application with Postgres DB as a source to read certain configuration data, convert it into a data stream and then join it with an incoming real-time data stream. I have tri...

I am trying to learn Flink and I am doing the basic WordCount tutorial. I was wondering how I could sort the output of a datastream so that it outputs the counts in descending order. I don't need this...