有一个疑问,我对于一个以kafka作为source的表做一个简单的Deduplication query,是没有问题。
当我用一个mysql作为source的表做一个简单的Deduplication query,暂时发现了3个问题
1、程序会输出完现有结果后(即已保存在mysql中的数据)就退出;
2、order by desc 输出的是第一条,asc输出的是最后一条,和官网描述相反;
3、时间莫名其妙加了13小时。
--
Sent from:
http://apache-flink.147419.n8.nabble.com/