fix ut

JNSimba · Aug 9, 2024 · b1f502a · b1f502a
1 parent fbeb7f0
commit b1f502a
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/...k-doris-connector/src/test/java/org/apache/doris/flink/cfg/DorisExecutionOptionsTest.java b/...k-doris-connector/src/test/java/org/apache/doris/flink/cfg/DorisExecutionOptionsTest.java
@@ -52,9 +52,9 @@ public void testEquals() {
                         .setWriteMode(WriteMode.STREAM_LOAD)
                         .setLabelPrefix("doris")
                         .enable2PC()
-                        .setBufferFlushMaxBytes(10)
+                        .setBufferFlushMaxBytes(524288001)
                         .setBufferFlushIntervalMs(10000)
-                        .setBufferFlushMaxRows(12)
+                        .setBufferFlushMaxRows(500001)
                         .setCheckInterval(10)
                         .setIgnoreCommitError(true)
                         .setDeletable(true)
@@ -72,9 +72,9 @@ public void testEquals() {
                         .setWriteMode(WriteMode.STREAM_LOAD)
                         .setLabelPrefix("doris")
                         .enable2PC()
-                        .setBufferFlushMaxBytes(10)
+                        .setBufferFlushMaxBytes(524288001)
                         .setBufferFlushIntervalMs(10000)
-                        .setBufferFlushMaxRows(12)
+                        .setBufferFlushMaxRows(500001)
                         .setCheckInterval(10)
                         .setIgnoreCommitError(true)
                         .setDeletable(true)
@@ -111,17 +111,17 @@ public void testEquals() {
         Assert.assertNotEquals(exceptOptions, builder.build());
         builder.enable2PC();
 
-        builder.setBufferFlushMaxBytes(11);
+        builder.setBufferFlushMaxBytes(524288002);
         Assert.assertNotEquals(exceptOptions, builder.build());
-        builder.setBufferFlushMaxBytes(10);
+        builder.setBufferFlushMaxBytes(524288001);
 
         builder.setBufferFlushIntervalMs(100001);
         Assert.assertNotEquals(exceptOptions, builder.build());
         builder.setBufferFlushIntervalMs(10000);
 
-        builder.setBufferFlushMaxRows(2);
+        builder.setBufferFlushMaxRows(500002);
         Assert.assertNotEquals(exceptOptions, builder.build());
-        builder.setBufferFlushMaxRows(12);
+        builder.setBufferFlushMaxRows(500001);
 
         builder.setCheckInterval(11);
         Assert.assertNotEquals(exceptOptions, builder.build());

diff --git a/...is-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java b/...is-connector/src/test/java/org/apache/doris/flink/table/DorisDynamicTableFactoryTest.java
@@ -132,8 +132,8 @@ public void testDorisSinkProperties() {
         properties.put("sink.use-cache", "true");
         properties.put("sink.enable.batch-mode", "true");
         properties.put("sink.flush.queue-size", "2");
-        properties.put("sink.buffer-flush.max-rows", "1000");
-        properties.put("sink.buffer-flush.max-bytes", "10MB");
+        properties.put("sink.buffer-flush.max-rows", "50000");
+        properties.put("sink.buffer-flush.max-bytes", "50MB");
         properties.put("sink.buffer-flush.interval", "10s");
         properties.put("sink.ignore.update-before", "true");
         properties.put("sink.ignore.commit-error", "false");
@@ -165,8 +165,8 @@ public void testDorisSinkProperties() {
                         .setBatchMode(true)
                         .enable2PC()
                         .setBufferFlushIntervalMs(10000)
-                        .setBufferFlushMaxBytes(10 * 1024 * 1024)
-                        .setBufferFlushMaxRows(1000)
+                        .setBufferFlushMaxBytes(50 * 1024 * 1024)
+                        .setBufferFlushMaxRows(50000)
                         .setFlushQueueSize(2)
                         .setUseCache(true)
                         .setIgnoreCommitError(false)