(incubator-paimon) branch master updated: [test] Fix bucket in micro benchmark

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new eef403b38 [test] Fix bucket in micro benchmark
eef403b38 is described below

commit eef403b3838465d869eb8cc343661afead7a6913
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Wed Feb 28 21:24:51 2024 +0800

    [test] Fix bucket in micro benchmark
---
 .../src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java    | 1 +
 .../src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java  | 1 +
 2 files changed, 2 insertions(+)

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 3471197fc..f089ef234 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 @@ public class TableReadBenchmark extends TableBenchmark {
     }
 
     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 8278eb721..5ced4248b 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 class TableWriterBenchmark extends TableBenchmark {
     }
 
     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();