[test] Fix bucket in micro benchmark

apache · Feb 28, 2024 · eef403b · eef403b
1 parent 508411d
commit eef403b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/...paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java b/...paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableReadBenchmark.java
@@ -112,6 +112,7 @@ private void innerTest(Map<String, Table> 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/...imon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java b/...imon-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();