[FLINK-22102][hive] Throw meaningful exceptions for unsupported DDLs (a…

…pache#15515)
deepfield · Apr 8, 2021 · 561fabb · 561fabb
1 parent 8550d82
commit 561fabb
Show file tree

Hide file tree

Showing 3 changed files with 188 additions and 425 deletions.
diff --git a/...nnector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java b/...nnector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java
@@ -21,6 +21,7 @@
 import org.apache.flink.connectors.hive.FlinkHiveException;
 import org.apache.flink.table.api.SqlParserException;
 import org.apache.flink.table.api.TableSchema;
+import org.apache.flink.table.api.ValidationException;
 import org.apache.flink.table.catalog.Catalog;
 import org.apache.flink.table.catalog.CatalogManager;
 import org.apache.flink.table.catalog.hive.HiveCatalog;
@@ -161,7 +162,8 @@ public class HiveParser extends ParserImpl {
  HiveASTParser.TOK_DROPFUNCTION,
  HiveASTParser.TOK_RELOADFUNCTION,
  HiveASTParser.TOK_CREATEVIEW,
- HiveASTParser.TOK_ALTERDATABASE_LOCATION));
+ HiveASTParser.TOK_ALTERDATABASE_LOCATION,
+ HiveASTParser.TOK_CREATE_MATERIALIZED_VIEW));
  }
 
  private final PlannerContext plannerContext;
@@ -233,10 +235,7 @@ private List<Operation> processCmd(
  HiveParserQueryState queryState = new HiveParserQueryState(hiveConf);
  HiveParserDDLSemanticAnalyzer ddlAnalyzer =
  new HiveParserDDLSemanticAnalyzer(
- queryState,
- context,
- hiveCatalog,
- getCatalogManager().getCurrentDatabase());
+ queryState, hiveCatalog, getCatalogManager().getCurrentDatabase());
  Serializable work = ddlAnalyzer.analyzeInternal(node);
  DDLOperationConverter ddlConverter =
  new DDLOperationConverter(this, getCatalogManager(), hiveShim);
@@ -291,7 +290,7 @@ private List<Operation> processCmd(
  throw new SqlParserException("SQL parse failed", e);
  }
  } catch (SemanticException e) {
- throw new FlinkHiveException("HiveParser failed to parse " + cmd, e);
+ throw new ValidationException("HiveParser failed to parse " + cmd, e);
  }
  }