[flink] 09/16: Fix statement

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch pull/19923/head
in repository https://gitbox.apache.org/repos/asf/flink.git

commit cc61f35337ffe50961faa2300604a879aa149e91
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Sep 14 17:11:29 2022 +0200

    Fix statement
---
 .../flink-sql-client-test/src/test/java/SqlClientITCase.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
 
b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
index b288d80298a..184ba25b2d0 100644
--- 
a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
+++ 
b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
@@ -234,7 +234,7 @@ public class SqlClientITCase {
                         "    PATTERN (A)",
                         "    DEFINE",
                         "        A as `user` = 'Alice'",
-                        "  ) T");
+                        "  ) as T;");
         executeSql(sqlLines);
 
         verifyNumberOfResultRecords(outputFilepath, 1);