Hi all,
I have a Paimon table that is continuously populated by a streaming job
based on incoming data.
I need to evict records from the table once they are no longer used—where
"not used" can be defined by a SQL query.
>From what I’ve observed, running such a query in a separate batch job
requir
Just adding user@flink.apache.org
On Fri, 21 Mar 2025 at 19:08, Kirill Lyashko
wrote:
> Ok, I'll ask them as well, thanks.
>
> On Fri, 21 Mar 2025 at 18:16, Alexey Novakov wrote:
>
>> This is really weird.
>>
>> I would recommend you also to ask on Flink D
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
