Question about match_recognize clause in Flink

Hello, I am using custom made connector to create Source table in this way: create table Source ( ts TIMESTAMP(3), instance STRING, sservice STRING, logdatetime STRING, threadid STRING, level STRING, log_line STRING ) with (

Interrupt collect() function when reading from kafka topic (in pyflink)

Hello, I have a simple source table (which is using kafka connector) that's reading and storing data from specific kafka topic. I also have print table: > t_env.execute_sql(""" > CREATE TABLE print ( > window_start TIMESTAMP(3), > window_end TIMESTAMP(3), >