fixup! Implement complex join pushdown in JDBC connectors

trinodb · Dec 8, 2023 · bfbc2b2 · bfbc2b2
1 parent c8557f8
commit bfbc2b2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/DefaultJdbcMetadata.java
@@ -498,7 +498,7 @@ public Optional<JoinApplicationResult<ConnectorTableHandle>> applyJoin(
                         .collect(toImmutableMap(Entry::getKey, entry -> newLeftColumns.get((JdbcColumnHandle) entry.getValue()))))
                 .putAll(rightAssignments.entrySet().stream()
                         .collect(toImmutableMap(Entry::getKey, entry -> newRightColumns.get((JdbcColumnHandle) entry.getValue()))))
-                .build();
+                .buildOrThrow();
 
         ImmutableList.Builder<ParameterizedExpression> joinConditions = ImmutableList.builder();
         for (ConnectorExpression conjunct : extractConjuncts(joinCondition)) {