You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/09/14 16:34:16 UTC
[flink] 05/16: Fix assertions
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 <ch...@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) {