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]