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 13012d2a9717b2de6142983f8171667b51a6cccc
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Sep 14 17:05:38 2022 +0200
Combine testMatchRecognize statements
Needs to be one statement such that everything runs in the same client, and
not 2 entirely separate ones.
---
.../flink-sql-client-test/src/test/java/SqlClientITCase.java | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
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 d9b4b5514d8..b04898f2753 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
@@ -219,11 +219,8 @@ public class SqlClientITCase {
" 'key.format' = 'json',",
" 'value.format' = 'json',",
" 'output-filepath' = '" + outputFilepath + "'",
- " );");
- executeSql(sqlLines);
-
- sqlLines =
- Arrays.asList(
+ " );",
+ "",
"INSERT INTO AppendSinkTable",
" SELECT 1 as user_id, T.userName as user_name,
cast(1 as BIGINT) as user_count",
" FROM (",
