Skip to content
This repository was archived by the owner on May 9, 2024. It is now read-only.

Commit 1604f97

Browse files
committed
Throw an exception for unknown tables is RelAlg JSON.
Signed-off-by: ienkovich <[email protected]>
1 parent 4f1cbdb commit 1604f97

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

omniscidb/Calcite/java/calcite/src/main/java/org/apache/calcite/rel/externalize/MapDRelJsonReader.java

+3-2
Original file line numberDiff line numberDiff line change
@@ -269,8 +269,9 @@ public ImmutableList<RexLiteral> getTuple(List jsonTuple) {
269269
Objects.requireNonNull(relOptSchema);
270270
Objects.requireNonNull(jsonRel);
271271
Objects.requireNonNull(jsonRel.get("table"));
272-
Objects.requireNonNull(
273-
relOptSchema.getTableForMember((List<String>) jsonRel.get("table")));
272+
if (relOptSchema.getTableForMember((List<String>) jsonRel.get("table")) == null) {
273+
throw new RuntimeException("unknown table: " + jsonRel.get("table"));
274+
}
274275
rel = EnumerableTableScan.create(cluster,
275276
relOptSchema.getTableForMember((List<String>) jsonRel.get("table")));
276277
}

0 commit comments

Comments
 (0)