jffwang
/
hetu-core
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

avoid index out of boundary error on dynamic filtering register tasks

This commit is contained in:
ZhanLu00 2021-02-25 13:57:27 -05:00
parent e18cb773ef
commit e7251c1010
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
presto-main/src/main/java/io/prestosql/dynamicfilter/DynamicFilterService.java
View File

@ -299,7 +299,13 @@ public class DynamicFilterService
}
if (node instanceof JoinNode) {
JoinNode joinNode = (JoinNode) node;
registerTasksHelper(node, joinNode.getCriteria().get(0).getRight(), joinNode.getDynamicFilters(), taskIds, workers, stateMachine);
List<JoinNode.EquiJoinClause> criterias = joinNode.getCriteria();
if (!criterias.isEmpty()) {
registerTasksHelper(node, criterias.get(0).getRight(), joinNode.getDynamicFilters(), taskIds, workers, stateMachine);
}
else {
log.warn("registerTasks is empty");
}
}
else if (node instanceof SemiJoinNode) {
SemiJoinNode semiJoinNode = (SemiJoinNode) node;