[ 
https://issues.apache.org/jira/browse/FLINK-41310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

ASF GitHub Bot updated FLINK-41310:
-----------------------------------
    Labels: pull-request-available  (was: )

> BatchExecAdaptiveJoin should take external-buffer-memory from the compiled 
> plan
> -------------------------------------------------------------------------------
>
>                 Key: FLINK-41310
>                 URL: https://issues.apache.org/jira/browse/FLINK-41310
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / Planner
>    Affects Versions: 2.5.0
>            Reporter: Bonnie Varghese
>            Assignee: Bonnie Varghese
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 2.5.0
>
>
> {\{BatchExecAdaptiveJoin}} computes the join's managed memory budget at 
> translation time from the node's config, but builds the operator at runtime, 
> where it reads \{{table.exec.resource.external-buffer-memory}} from the job 
> config. The buffer is a share of that budget, so both values should come from 
> the same config.
> {\{BatchExecHashJoin}} and \{{BatchExecSortMergeJoin}} read both values at 
> translation time. The adaptive join only decides the join strategy at 
> runtime; its memory budget is already fixed before it runs.
> This should be fixed after FLINK-41263 is merged.



--
This message was sent by Atlassian Jira
(v10.3.26#10030026)

Reply via email to