Hi all, I encountered a suspected bug in Flink. A flink job associates with 30+ HBase2.2 asynchronous dimension tables(Temporal Join AND lookup.async = 'true'), When I submitted this job, it took a very long time to submit to the YARN cluster. During the generation of the job graph and optimization of the operator chain, recursion occurs in the process of locating and discovering.
Flink source code location: version 1.14 org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator#areOperatorsChainable liu...@midea.com