回复: Flink 1.11 table.executeInsert 程序退出

2020-09-29 文章 史 正超
主题: Flink 1.11 table.executeInsert 程序退出 当我在使用 StreamTableEnvironment Api的时候； Table a = getStreamTable(getKafkaDataStream("test", "localhost:9092", "latest"),"topic,offset,msg"); tableEnv.createTemporaryView("test", a); tableEn

Flink 1.11 table.executeInsert 程序退出

2020-09-29 文章 HunterXHunter
当我在使用 StreamTableEnvironment Api的时候； Table a = getStreamTable(getKafkaDataStream("test", "localhost:9092", "latest"),"topic,offset,msg"); tableEnv.createTemporaryView("test", a); tableEnv.executeSql(DDLSourceSQLManager.createCustomPrintlnRetractSinkTbl("printlnSink_retract"));