Flink 1.11 table.executeInsert 程序退出

Tue, 29 Sep 2020 19:40:58 -0700 

当我在使用 StreamTableEnvironment Api的时候；

 Table a = getStreamTable(getKafkaDataStream("test", "localhost:9092",
"latest"),"topic,offset,msg");
  tableEnv.createTemporaryView("test", a);
 
tableEnv.executeSql(DDLSourceSQLManager.createCustomPrintlnRetractSinkTbl("printlnSink_retract"));
  tableEnv.executeSql("insert into printlnSink_retract select
topic,msg,count(*) as ll from test group by topic,msg");

程序直接结束退出，但如果最后加Thread.sleep(10000L) 就可以消费10s钟，如果加
tableEnv.execute("jobname");
报错：No operators defined in streaming topology



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复