spena commented on code in PR #25359:
URL: https://github.com/apache/flink/pull/25359#discussion_r1768799089
##########
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/utils/ParserResource.java:
##########
@@ -41,6 +41,10 @@ public interface ParserResource {
@Resources.BaseMessage("Duplicate EXPLAIN DETAIL is not allowed.")
Resources.ExInst<ParseException> explainDetailIsDuplicate();
+ @Resources.BaseMessage(
+ "CREATE OR REPLACE statement not supported by EXPLAIN. Only
CTAS/RTAS statements are supported.")
Review Comment:
Done
##########
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/DynamicSinkUtils.java:
##########
@@ -209,6 +213,78 @@ public static RelNode convertSinkToRel(
sink);
}
+ /**
+ * Converts a given {@link DynamicTableSink} to a {@link RelNode}. It adds
helper projections if
+ * necessary.
+ */
+ public static RelNode convertCtasToRel(
Review Comment:
Done
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
