xingbe created FLINK-37382: ------------------------------ Summary: Early optimization for adaptive join when one input is below broadcast threshold Key: FLINK-37382 URL: https://issues.apache.org/jira/browse/FLINK-37382 Project: Flink Issue Type: Sub-task Components: Runtime / Coordination Affects Versions: 2.0.0 Reporter: xingbe
When the large table side has not yet initialized, if the small table side finishes early and the output data volume is smaller than the broadcast threshold, the adaptive join operator can be optimized to a broadcast hash join in advance. This can help reduce network shuffle overhead. -- This message was sent by Atlassian Jira (v8.20.10#820010)