flink读取oracle的问题

图1 图2 问题1：程序运行结束后，records received最终的数量正确，这个task的records sent数量是2倍，最终sink到hbase时候receive的数据量也是正确的，为什么中间sent要两倍？ 问题2：在第一个task，是批处理读取oracle数据，无论设置多少并行度，都会只有一个在处理数据，这是为啥可以并行读取吗

>>阅读原文<<