Submitting multiple DELETE statements in Flink SQL

I' m trying to submit multiple DELETE statements in to the TableEnvironment in way: val settings = EnvironmentSettings.newInstance.inBatchMode.build() val env = TableEnvironment.create(settings) createSchema(env) val queries = getDeleteQueries queries.foreach(q => env.executeSql(q).await()) what

Flink checkpoints, is this OK?

Hi all. I would like to ask if what I am seeing is good or not. We are running Flink as Kubernetes session cluster and have checkpoints enabled. When I inspect a checkpoint, I can see only one file: „_metadata“. As I understand it, that is OK, if the state in question is sufficiently small to f