cuspymd commented on a change in pull request #15986:
URL: https://github.com/apache/flink/pull/15986#discussion_r638628377
##########
File path:
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java
##########
@@ -844,16 +843,19 @@ private Operation convertShowViews(SqlShowViews
sqlShowViews) {
return new ShowViewsOperation();
}
- /** Convert EXPLAIN statement. */
- private Operation convertExplain(SqlExplain sqlExplain) {
- Operation operation = convertSqlQuery(sqlExplain.getExplicandum());
-
- if (sqlExplain.getDetailLevel() != SqlExplainLevel.EXPPLAN_ATTRIBUTES
- || sqlExplain.getDepth() != SqlExplain.Depth.PHYSICAL
- || sqlExplain.getFormat() != SqlExplainFormat.TEXT) {
- throw new TableException("Only default behavior is supported now,
EXPLAIN PLAN FOR xx");
+ /** Convert RICH EXPLAIN statement. */
+ private Operation convertRichExplain(SqlRichExplain sqlExplain) {
+ Operation operation;
+ SqlNode sqlNode = sqlExplain.getStatement();
+ if (sqlNode instanceof RichSqlInsert) {
+ operation = convertSqlInsert((RichSqlInsert) sqlNode);
+ } else if (sqlNode instanceof SqlSelect) {
+ operation = convertSqlQuery(sqlExplain.getStatement());
Review comment:
Do you mean that the results of executions 1 and 2 below are different?
```
// 1
convertSqlQuery(sqlExplain.getStatement());
// 2
convertSqlQuery(sqlNode);
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
