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

Reply via email to