你好， 你的flink版本是多少？ 之前有个bug是Table转datastream 会丢rowtime问题，看起来是这个问题。
我在[1]里修复了，你可以升级对应的版本试下。 祝好， Leonard [1]https://issues.apache.org/jira/browse/FLINK-21013 <https://issues.apache.org/jira/browse/FLINK-21013> > 在 2021年3月10日，14:34，HunterXHunter <[email protected]> 写道： > > 再试了一下： > 修改并行度也不行 > .setParallelism(9) > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
