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 66cf373b1ffa9ab6cde1f9eee6520da94b016990 Author: Chesnay Schepler <ches...@apache.org> AuthorDate: Wed Sep 14 17:04:06 2022 +0200 Fix assertions --- .../flink-sql-client-test/src/test/java/SqlClientITCase.java | 4 ++-- 1 file changed, 2 insertions(+), 2 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 894c581fded..7b6d91e6fd3 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 @@ -169,7 +169,7 @@ public class SqlClientITCase { " AS UserCountTable(user_id, user_name, user_count);"); executeSql(sqlLines); - verifyNumberOfResultRecords(outputFilepath, 6); + verifyNumberOfResultRecords(outputFilepath, 3); } @Test @@ -242,7 +242,7 @@ public class SqlClientITCase { " ) T"); executeSql(sqlLines); - verifyNumberOfResultRecords(outputFilepath, 3); + verifyNumberOfResultRecords(outputFilepath, 1); } public void sendMessages(String topic, String... messages) {