Written by 
I’m trying to understand how watermarks work in FlinkSQL. I’ve created the following tables: CREATE TABLE currency_rates ( currency STRING, conversion_rate STRING, update_time TIMESTAMP(3), WATERMARK FOR update_time AS update_time, PRIMARY KEY(currency) NOT ENFORCED ) WITH ( ‘connector’ = ‘upsert-kafka’, ‘topic’ = ‘currency_rates’, ‘properties.bootstrap.servers’ = ‘kafka:9092’, ‘properties.group.id’ = ‘currency_rates1’, ‘key.format’ = ‘raw’, ‘value.format’ = ‘avro’, ‘properties.auto.offset.reset’ […]
Robust Distortion-free Watermarks for Language Models Source link