Good evening all, We are running a job in flink SQL. We've confirmed all Kafka topics that we are sourcing from have 5 partitions. All source tasks in the larger DAG, of which we're only showing a small portion of it below, have a parallelism of 5. But for some reason, this one little guy here (to which we can not figure out which part of the query he belongs to) decides to not parallelize. The task following him though IS parallelized again.
What is the most common cause for this? Does it have anything to do with the arrows pointing to him and their labels saying GLOBAL? How can we go about pinpointing which part of our query belongs to that specific task? We have 104 tasks, so quickly pinpointing the exact part of the query would help us out alot. Thank you Jason Politis Solutions Architect, Carrera Group carrera.io | jpoli...@carrera.io <kpatter...@carrera.io> <http://us.linkedin.com/in/jasonpolitis>
