This is an automated email from the ASF dual-hosted git repository. diwu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push: new 386613d6 [improve](test-case) modify ut for batch streamload (#396) 386613d6 is described below commit 386613d66617436d977450922e3b1548df8aaf76 Author: wudi <676366...@qq.com> AuthorDate: Thu Jun 6 10:04:09 2024 +0800 [improve](test-case) modify ut for batch streamload (#396) --- .../org/apache/doris/flink/sink/batch/TestDorisBatchStreamLoad.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchStreamLoad.java b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchStreamLoad.java index 3ccef825..d73ff440 100644 --- a/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchStreamLoad.java +++ b/flink-doris-connector/src/test/java/org/apache/doris/flink/sink/batch/TestDorisBatchStreamLoad.java @@ -23,7 +23,6 @@ import org.apache.flink.util.function.SupplierWithException; import org.apache.doris.flink.cfg.DorisExecutionOptions; import org.apache.doris.flink.cfg.DorisOptions; import org.apache.doris.flink.cfg.DorisReadOptions; -import org.apache.doris.flink.exception.DorisBatchLoadException; import org.apache.doris.flink.sink.BackendUtil; import org.apache.doris.flink.sink.HttpTestUtil; import org.apache.doris.flink.sink.writer.LabelGenerator; @@ -119,7 +118,7 @@ public class TestDorisBatchStreamLoad { loader.flush("db.tbl", true); AtomicReference<Throwable> exception = loader.getException(); - Assert.assertEquals(exception.get().getClass(), DorisBatchLoadException.class); + Assert.assertTrue(exception.get() instanceof Exception); Assert.assertTrue(exception.get().getMessage().contains("stream load error")); } @@ -159,7 +158,7 @@ public class TestDorisBatchStreamLoad { AtomicReference<Throwable> exception = loader.getException(); - Assert.assertEquals(exception.get().getClass(), DorisBatchLoadException.class); + Assert.assertTrue(exception.get() instanceof Exception); Assert.assertTrue(exception.get().getMessage().contains("stream load error")); } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org