xiaodao created FLINK-14801:
-------------------------------
Summary: flink sql parser unparser func partition frame local
variable name mistake
Key: FLINK-14801
URL: https://issues.apache.org/jira/browse/FLINK-14801
Project: Flink
Issue Type: Improvement
Components: Table SQL / API
Affects Versions: 1.9.1
Reporter: xiaodao
Fix For: 1.10.0
in the class org.apache.flink.sql.parser.ddl.SqlCreateTable#unparse
{code:java}
//代码占位符
if (this.partitionKeyList != null && this.partitionKeyList.size() > 0) {
writer.newlineAndIndent(); writer.keyword("PARTITIONED BY");
{color:red}SqlWriter.Frame withFrame = writer.startList("(", ")");{color}
this.partitionKeyList.unparse(writer, leftPrec, rightPrec);
writer.endList(withFrame); writer.newlineAndIndent(); }
{code}
it's better to modify name withFrame to partitionedByFrame
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
