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

Background We want to keep in a Flink operator's state the last n unique id's. When the n+1 unique id arrives, we want to keep it and drop the oldest unique id in the state. This is in order to avoid ...

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 have a requirement to delay processing of some of the events. eg. I have three events (Consumer Kafka): A (id: 1, retryAt: now) B (id: 2, retryAt: 15 minutes later) C (id: 3, retryAt: now) I need t...