diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/rest/TestRestService.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/rest/TestRestService.java index ef59ef418..42487acf8 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/rest/TestRestService.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/rest/TestRestService.java @@ -114,6 +114,9 @@ public void testParseIdentifierIllegalEmpty() throws IllegalArgumentException { @Test public void testParseIdentifierIllegal() throws Exception { String invalidIdentifier3 = "a.b.c"; + RestService.parseIdentifier(invalidIdentifier3, logger); + + invalidIdentifier3 = "a.b.c.d.e"; thrown.expect(IllegalArgumentException.class); thrown.expectMessage( "argument 'table.identifier' is illegal, value is '" + invalidIdentifier3 + "'.");