Согласно официальным документам Флинка, атрибут времени будет потерян после объединения двух потоков. Но я хочу сделать операцию TimeWindow после объединений, которая требует, чтобы поток имел атрибут времени. Я снова преобразовываю таблицу в поток данных и назначаю метки времени и водяной знак, а затем преобразую результат в таблицу, используя tableEnv.fromDataStream (). Приложение выдает исключение. Хорошо, может быть, оно недоступно. Есть способы сделать это?