Re: 关于flink cdc sql转出Stream流问题
可以使用这种方式: DataStream dstream = tableEnv.toAppendStream(sourceTable, RowData.class); -- Sent from: http://apache-flink.147419.n8.nabble.com/
Re: flink timerservice注册的timer定时器只有少部分触发
试试 重写 onTimer 方法 可以参考 https://github.com/JSQF/flink10_learn/blob/master/src/main/scala/com/yyb/flink10/DataStream/ProcessFunction/OperatorProcessFunctionDemo.java -- Sent from: http://apache-flink.147419.n8.nabble.com/