Я работаю с двумя потоками от Kafka, хотя один из них встречается не так часто.
Я попытался выполнить объединение, и оно сработало, но память накапливалась всего за несколько часов, и работа не удалась. Моя политика хранения установлена на 1 день, я знаю, что не смог выполнить window объединений в обеих динамических таблицах. Кроме того, я не думаю, что могу рассматривать непериодический поток как функцию временной таблицы.
Я использую v1.9 и клиент SQL, а не Table API.
Помогите мне решить сценарий использования. Спасибо.