snuyanzin commented on code in PR #27488:
URL: https://github.com/apache/flink/pull/27488#discussion_r2740342956


##########
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableChange.java:
##########
@@ -386,8 +386,9 @@ static ModifyRefreshHandler modifyRefreshHandler(
      * @param definitionQuery the modified definition query.
      * @return a TableChange represents the modification.
      */
-    static ModifyDefinitionQuery modifyDefinitionQuery(String definitionQuery) 
{
-        return new ModifyDefinitionQuery(definitionQuery);
+    static ModifyDefinitionQuery modifyDefinitionQuery(

Review Comment:
   looks like it was missed when original query was added



-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to