diff --git a/presto-hive/src/main/java/io/prestosql/plugin/hive/HivePageSource.java b/presto-hive/src/main/java/io/prestosql/plugin/hive/HivePageSource.java index 324c3fc55..1a515cf72 100644 --- a/presto-hive/src/main/java/io/prestosql/plugin/hive/HivePageSource.java +++ b/presto-hive/src/main/java/io/prestosql/plugin/hive/HivePageSource.java @@ -307,6 +307,7 @@ public class HivePageSource private List> getEligibleColumnsForRowFiltering(int channelCount, List> dynamicFilters) { + boolean eligibleFilterFound = false; List> eligibleColumnsList = new ArrayList<>(); for (Map dynamicFilter : dynamicFilters) { Map eligibleColumns = new HashMap<>(); @@ -319,8 +320,15 @@ public class HivePageSource } } + if (eligibleColumns.size() > 0) { + eligibleFilterFound = true; + } eligibleColumnsList.add(eligibleColumns); } + + if (eligibleFilterFound == false) { + return new ArrayList<>(); + } return eligibleColumnsList; }