flink讀取oracle的問題

圖1 圖2 問題1：程序運行結束後，records received最終的數量正確，這個task的records sent數量是2倍，最終sink到hbase時候receive的數據量也是正確的，爲什麼中間sent要兩倍？ 問題2：在第一個task，是批處理讀取oracle數據，無論設置多少並行度，都會只有一個在處理數據，這是爲啥可以並行讀取嗎

>>阅读原文<<