Совместное использование динамических таблиц между программами Flink
#apache-flink #flink-sql Вопрос: У меня есть задание Flink, которое создает динамическую таблицу из потока списка изменений базы данных. Определение таблицы выглядит следующим образом: tableEnv.sqlUpdate(""" CREATE TABLE some_table_name ( id INTEGER,…