flink读取oracle的问题

图1

flink读取oracle的问题

图2flink读取oracle的问题

问题1:程序运行结束后,records received最终的数量正确,这个task的records sent数量是2倍,最终sink到hbase时候receive的数据量也是正确的,为什么中间sent要两倍?

问题2:在第一个task,是批处理读取oracle数据,无论设置多少并行度,都会只有一个在处理数据,这是为啥可以并行读取吗