From d44145767c937720bcd66e0cd91845f8f8edd266 Mon Sep 17 00:00:00 2001 From: Wei Guo Date: Thu, 11 Jul 2024 12:57:51 +0800 Subject: [PATCH] [benchmark] Fix the problem that parquet-related benchmark test cases call the wrong method in `TableReadBenchmark` class (#3728) --- .../apache/paimon/benchmark/TableReadBenchmark.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) 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 535ab7652095..80a68563115f 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 @@ -110,27 +110,28 @@ public void testOrcReadProjection1() throws Exception { @Test public void testParquetReadProjection() throws Exception { innerTestProjection( - Collections.singletonMap("parquet", prepareData(orc(), "parquet")), + Collections.singletonMap("parquet", prepareData(parquet(), "parquet")), new int[] {0, 5, 10, 14}); /* * OpenJDK 64-Bit Server VM 1.8.0_292-b10 on Mac OS X 10.16 * Apple M1 Pro * read: Best/Avg Time(ms) Row Rate(K/s) Per Row(ns) Relative * ------------------------------------------------------------------------------------------------ - * OPERATORTEST_read_read-orc 716 / 728 4187.4 238.8 1.0X + * OPERATORTEST_read_read-parquet 716 / 728 4187.4 238.8 1.0X */ } @Test public void testParquetReadProjection1() throws Exception { innerTestProjection( - Collections.singletonMap("parquet", prepareData(orc(), "parquet")), new int[] {10}); + Collections.singletonMap("parquet", prepareData(parquet(), "parquet")), + new int[] {10}); /* * OpenJDK 64-Bit Server VM 1.8.0_292-b10 on Mac OS X 10.16 * Apple M1 Pro * read: Best/Avg Time(ms) Row Rate(K/s) Per Row(ns) Relative * ------------------------------------------------------------------------------------------------ - * OPERATORTEST_read_read-orc 716 / 728 4187.4 238.8 1.0X + * OPERATORTEST_read_read-parquet 716 / 728 4187.4 238.8 1.0X */ } @@ -142,7 +143,7 @@ private Options orc() { private Options parquet() { Options options = new Options(); - options.set(CoreOptions.FILE_FORMAT, CoreOptions.FILE_FORMAT_ORC); + options.set(CoreOptions.FILE_FORMAT, CoreOptions.FILE_FORMAT_PARQUET); return options; }