Hi:
   I'm not familar with batch api .And I write a program  just like
"insert  into tab_a select  * from tab_b".
   From the picture, there are only two tasks, one is the source task which
is in RUNNING state. And the other one is sink task which is always in
CREATE state.
   According to logs, I found that  source task is reading the file I
specified now, in other words, it is working normally.
   Doesn't flink work after all operators are initialized?


[image: image.png]

Reply via email to