diff --git a/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java index 3471197fc6c7..f089ef234c42 100644 --- a/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java +++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java @@ -112,6 +112,7 @@ private void innerTest(Map tables) { } private Table prepareData(Options options, String tableName) throws Exception { + options.set(CoreOptions.BUCKET, 1); Table table = createTable(options, tableName); StreamWriteBuilder writeBuilder = table.newStreamWriteBuilder(); StreamTableWrite write = writeBuilder.newWrite(); diff --git a/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java index 8278eb721957..5ced4248bffa 100644 --- a/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java +++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java @@ -106,6 +106,7 @@ public void testOrc() throws Exception { } public void innerTest(String name, Options options) throws Exception { + options.set(CoreOptions.BUCKET, 1); StreamWriteBuilder writeBuilder = createTable(options, "T").newStreamWriteBuilder(); StreamTableWrite write = writeBuilder.newWrite(); StreamTableCommit commit = writeBuilder.newCommit();