Update DynamicFilters.java

codluca · codluca · commit a6880afdead5 · 2025-09-24T20:30:09.000+03:00
diff --git a/core/trino-main/src/main/java/io/trino/sql/DynamicFilters.java b/core/trino-main/src/main/java/io/trino/sql/DynamicFilters.java
@@ -305,8 +305,8 @@ public Domain applyComparison(Domain domain)
             Range span = domain.getValues().getRanges().getSpan();
             return switch (operator) {
                 case EQUAL -> {
-                    if (!nullAllowed && domain.isNullAllowed()) {
-                        yield Domain.create(domain.getValues(), false);
+                    if (nullAllowed != domain.isNullAllowed()) {
+                        yield Domain.create(domain.getValues(), nullAllowed);
                     }
                     yield domain;
                 }

Original file line number	Diff line number	Diff line change
`@@ -305,8 +305,8 @@ public Domain applyComparison(Domain domain)`
`305`	`305`	`Range span = domain.getValues().getRanges().getSpan();`
`306`	`306`	`return switch (operator) {`
`307`	`307`	`case EQUAL -> {`
`308`		`- if (!nullAllowed && domain.isNullAllowed()) {`
`309`		`- yield Domain.create(domain.getValues(), false);`
	`308`	`+ if (nullAllowed != domain.isNullAllowed()) {`
	`309`	`+ yield Domain.create(domain.getValues(), nullAllowed);`
`310`	`310`	`}`
`311`	`311`	`yield domain;`
`312`	`312`	`}`