diff --git a/tajo-core/src/main/java/org/apache/tajo/engine/planner/PreLogicalPlanVerifier.java b/tajo-core/src/main/java/org/apache/tajo/engine/planner/PreLogicalPlanVerifier.java index 75dcc18180..7f5200d8e8 100644 --- a/tajo-core/src/main/java/org/apache/tajo/engine/planner/PreLogicalPlanVerifier.java +++ b/tajo-core/src/main/java/org/apache/tajo/engine/planner/PreLogicalPlanVerifier.java @@ -254,6 +254,10 @@ public Expr visitInsert(Context context, Stack stack, Insert expr) throws } TableDesc table = catalog.getTableDesc(qualifiedName); + if (table == null) { + context.state.addVerification(String.format("relation \"%s\" does not exist", qualifiedName)); + return null; + } if (table.hasPartition()) { int columnSize = table.getSchema().getColumns().size(); columnSize += table.getPartitionMethod().getExpressionSchema().getColumns().size();