图1

flink读取oracle的问题

图2flink读取oracle的问题

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

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

相关文章:

  • 2022-12-23
  • 2022-12-23
  • 2021-09-17
  • 2021-05-11
  • 2022-02-13
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2021-07-20
  • 2021-08-18
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-10-04
  • 2022-02-02
相关资源
相似解决方案