Skip to content

Commit 9d7afcd

Browse files
committed
[hotfix][table] Use two spaces for MODIFY DEFINITION QUERY
1 parent 992062e commit 9d7afcd

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ private static String toString(TableChange tableChange) {
119119
} else if (tableChange instanceof ModifyDefinitionQuery) {
120120
ModifyDefinitionQuery definitionQuery = (ModifyDefinitionQuery) tableChange;
121121
return String.format(
122-
" MODIFY DEFINITION QUERY TO '%s'", definitionQuery.getDefinitionQuery());
122+
" MODIFY DEFINITION QUERY TO '%s'", definitionQuery.getDefinitionQuery());
123123
} else {
124124
return AlterTableChangeOperation.toString(tableChange);
125125
}

flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,7 @@ void testCreateOrAlterMaterializedTableForExistingTable() throws TableNotExistEx
208208
"CREATE OR ALTER MATERIALIZED TABLE builtin.default.mt\n"
209209
+ " ADD `e` STRING ,\n"
210210
+ " ADD `f` STRING ,\n"
211-
+ " MODIFY DEFINITION QUERY TO 'SELECT `t1`.`a`, `t1`.`b`, `t1`.`c`, `t1`.`d`, `t1`.`d` AS `e`, CAST('123' AS STRING) AS `f`\n"
211+
+ " MODIFY DEFINITION QUERY TO 'SELECT `t1`.`a`, `t1`.`b`, `t1`.`c`, `t1`.`d`, `t1`.`d` AS `e`, CAST('123' AS STRING) AS `f`\n"
212212
+ "FROM `builtin`.`default`.`t1` AS `t1`',\n"
213213
+ " SET 'format' = 'json2',\n"
214214
+ " RESET 'connector',\n"

0 commit comments

Comments
 (0)