Re: 关于flink cdc sql转出Stream流问题

2020-11-30 文章 jsqf
可以使用这种方式: DataStream dstream = tableEnv.toAppendStream(sourceTable, RowData.class); -- Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink timerservice注册的timer定时器只有少部分触发

2020-08-06 文章 jsqf
试试 重写 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/