Как записать в таблицу s3 в flink без ошибки обновления и удаления изменений?

#java #amazon-s3 #apache-flink #flink-batch Вопрос: Рассмотрим код: import org.apache.flink.table.api.Table; import org.apache.flink.table.api.bridge.java.StreamTableEnvironment; class Scratch { public static void main(String[] args) { StreamTableEnvironment tableEnv = /*some init code here*/; tableEnv.executeSql("CREATE TABLE my_table…

Продолжить чтениеКак записать в таблицу s3 в flink без ошибки обновления и удаления изменений?