diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/committer/TestDorisCommitter.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/committer/TestDorisCommitter.java index f5c82bb1c..00bbaf621 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/committer/TestDorisCommitter.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/committer/TestDorisCommitter.java @@ -97,7 +97,7 @@ public void testCommitted() throws Exception { @Test public void testCommitAbort() throws Exception { thrown.expect(DorisRuntimeException.class); - thrown.expectMessage("commit transaction error"); + thrown.expectMessage("Commit transaction error"); String response = "{\n"