diff --git a/flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java b/flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java index e5317a739bd..2d0bb545178 100644 --- a/flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java +++ b/flink-connector/flink/src/test/java/org/apache/gravitino/flink/connector/integration/test/FlinkCommonIT.java @@ -314,33 +314,33 @@ public void testCreateTableWithPrimaryKey() { Index index = table.index()[0]; Assertions.assertEquals("aa", index.fieldNames()[0][0]); Assertions.assertEquals("bb", index.fieldNames()[1][0]); + TestUtils.assertTableResult( sql("INSERT INTO %s VALUES(1,2,3)", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(-1)); - TestUtils.assertTableResult( sql("SELECT count(*) num FROM %s", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(1)); TestUtils.assertTableResult( sql("SELECT * FROM %s", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(1, 2, 3)); + TestUtils.assertTableResult( sql("INSERT INTO %s VALUES(1,2,4)", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(-1)); - TestUtils.assertTableResult( sql("SELECT count(*) num FROM %s", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(1)); TestUtils.assertTableResult( sql("SELECT * FROM %s", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(1, 2, 4)); + TestUtils.assertTableResult( sql("INSERT INTO %s VALUES(1,3,4)", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(-1)); - TestUtils.assertTableResult( sql("SELECT count(*) num FROM %s", tableName), ResultKind.SUCCESS_WITH_CONTENT, @@ -350,11 +350,11 @@ public void testCreateTableWithPrimaryKey() { ResultKind.SUCCESS_WITH_CONTENT, Row.of(1, 2, 4), Row.of(1, 3, 4)); + TestUtils.assertTableResult( sql("INSERT INTO %s VALUES(2,2,4)", tableName), ResultKind.SUCCESS_WITH_CONTENT, Row.of(-1)); - TestUtils.assertTableResult( sql("SELECT count(*) num FROM %s", tableName), ResultKind.SUCCESS_WITH_CONTENT,