как получить последний результат при выполнении объединения таблиц (используя toRetractStream в flink sql
#apache-flink #flink-streaming #flink-sql #flink-table-api Вопрос: Вот мой код, использующий flink sql API для объединения двух таблиц tEnv.createTemporaryView("A", streamA,"speed_sum,cnt,window_start_time,window_end_time"); tEnv.createTemporaryView("B",streamB,"speed_sum,cnt,window_start_time,window_end_time"); String execSQL1 = "select A.speed_sum COALESCE(B.speed_sum,0.0), " "A.cnt COALESCE(B.cnt,0), " "A.window_start_time,…