From 274b4e73c3ec42e18e1075ee705cbc897d08c55b Mon Sep 17 00:00:00 2001 From: wyy566 <531938832@qq.com> Date: Fri, 5 Mar 2021 16:26:59 +0800 Subject: [PATCH] fix the problem of reuse exchange --- .../java/io/prestosql/spi/plan/TableScanNode.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/presto-spi/src/main/java/io/prestosql/spi/plan/TableScanNode.java b/presto-spi/src/main/java/io/prestosql/spi/plan/TableScanNode.java index 728029418..ce68c7626 100644 --- a/presto-spi/src/main/java/io/prestosql/spi/plan/TableScanNode.java +++ b/presto-spi/src/main/java/io/prestosql/spi/plan/TableScanNode.java @@ -312,13 +312,20 @@ public class TableScanNode public boolean isPredicateSame(TableScanNode curr) { + boolean returnValue = false; if (filterExpr != null) { - return filterExpr.absEquals(curr.getFilterExpr()); + returnValue = filterExpr.absEquals(curr.getFilterExpr()); } else if (curr.getFilterExpr() == null) { - return true; + returnValue = true; } + if (returnValue) { + if (predicate.isPresent()) { + return predicate.get().absEquals(curr.getPredicate().get()); + } + return true; + } return false; } }