update test params

Signed-off-by: zenghua <huazeng@dmetasoul.com>
lakesoul-io · Jun 4, 2024 · fde2f08 · fde2f08
1 parent eb99c1b
commit fde2f08
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...nk/src/test/java/org/apache/flink/lakesoul/test/connector/LakeSoulArrowConnectorCase.java b/...nk/src/test/java/org/apache/flink/lakesoul/test/connector/LakeSoulArrowConnectorCase.java
@@ -24,7 +24,7 @@ public void test() throws Exception {
         StreamExecutionEnvironment execEnv = LakeSoulTestUtils.createStreamExecutionEnvironment(parallelism, 2000L, 2000L);
         StreamTableEnvironment tableEnv = LakeSoulTestUtils.createTableEnvInStreamingMode(
                 execEnv, parallelism);
-        DataStreamSource<LakeSoulArrowWrapper> source = execEnv.addSource(new MockLakeSoulArrowSource.MockSourceFunction(500, 100L));
+        DataStreamSource<LakeSoulArrowWrapper> source = execEnv.addSource(new MockLakeSoulArrowSource.MockSourceFunction(100, 100L));
         String name = "Print Sink";
         PrintSinkFunction<LakeSoulArrowWrapper> printFunction = new PrintSinkFunction<>(name, false);