This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9d7afcd5e8f8c732877cbd5b8f444211684c18f3 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Tue Mar 24 11:17:57 2026 +0100 [hotfix][table] Use two spaces for `MODIFY DEFINITION QUERY` --- .../materializedtable/AlterMaterializedTableChangeOperation.java | 2 +- ...qlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperation.java b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperation.java index 0930b69f1ae..c6d42012565 100644 --- a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperation.java +++ b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/materializedtable/AlterMaterializedTableChangeOperation.java @@ -119,7 +119,7 @@ public class AlterMaterializedTableChangeOperation extends AlterMaterializedTabl } else if (tableChange instanceof ModifyDefinitionQuery) { ModifyDefinitionQuery definitionQuery = (ModifyDefinitionQuery) tableChange; return String.format( - " MODIFY DEFINITION QUERY TO '%s'", definitionQuery.getDefinitionQuery()); + " MODIFY DEFINITION QUERY TO '%s'", definitionQuery.getDefinitionQuery()); } else { return AlterTableChangeOperation.toString(tableChange); } diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest.java index 8a56e271d5f..95e7d1714cb 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest.java @@ -208,7 +208,7 @@ class SqlNodeToOperationSqlCreateOrAlterMaterializedTableConverterTest "CREATE OR ALTER MATERIALIZED TABLE builtin.default.mt\n" + " ADD `e` STRING ,\n" + " ADD `f` STRING ,\n" - + " MODIFY DEFINITION QUERY TO 'SELECT `t1`.`a`, `t1`.`b`, `t1`.`c`, `t1`.`d`, `t1`.`d` AS `e`, CAST('123' AS STRING) AS `f`\n" + + " MODIFY DEFINITION QUERY TO 'SELECT `t1`.`a`, `t1`.`b`, `t1`.`c`, `t1`.`d`, `t1`.`d` AS `e`, CAST('123' AS STRING) AS `f`\n" + "FROM `builtin`.`default`.`t1` AS `t1`',\n" + " SET 'format' = 'json2',\n" + " RESET 'connector',\n"
