[
https://issues.apache.org/jira/browse/FLINK-36629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-36629.
---------------------------
Fix Version/s: 2.0.0
Resolution: Done
ce42c0a6045cb3b81cbe279350a100759f6eb32b
c78097a56c56de695913a6d4e32d2c3edd040f70
ab1649e9500c05f1d1478f71c3e0d291d1573de3
df021354008135292c7c04785396cb0f0b0870ac
> Introducing the AdaptiveSkewedJoinOptimizationStrategy
> ------------------------------------------------------
>
> Key: FLINK-36629
> URL: https://issues.apache.org/jira/browse/FLINK-36629
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Lei Yang
> Assignee: Lei Yang
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.0.0
>
>
> The AdaptiveSkewedJoinOptimizationStrategy is responsible for adjusting the
> StreamGraph for the skewed join operators at the runtime stage before the
> scheduling of the AdaptiveJoin operator. It has the following works:
> # Introduce the capability to record edges that meet the conditions for
> adaptive skewed join optimization to BatchExecAdaptiveJoin and the capability
> to query optimizable skewed sides to the AdaptiveJoinOperatorFactory.
> # Determine whether to optimize for skewed join based on the skewness of the
> actual input data from upstream and the type of input edge in the
> AdaptiveSkewedJoinOptimizationStrategy.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
