You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2023/03/18 04:42:42 UTC
[incubator-paimon] 01/32: [core] Rename paimon benchmark
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
commit d7662df2dbc4a643ef5cbc149a3466933f568a30
Author: JingsongLi <lz...@aliyun.com>
AuthorDate: Fri Mar 17 12:00:59 2023 +0800
[core] Rename paimon benchmark
---
.../paimon-cluster-benchmark}/README.md | 0
.../paimon-cluster-benchmark}/pom.xml | 0
.../src/main/assemblies/bin.xml | 0
.../java/org/apache/paimon}/benchmark/Benchmark.java | 12 ++++++------
.../org/apache/paimon}/benchmark/BenchmarkOptions.java | 2 +-
.../main/java/org/apache/paimon}/benchmark/Query.java | 5 +++--
.../java/org/apache/paimon}/benchmark/QueryRunner.java | 16 ++++++++--------
.../src/main/java/org/apache/paimon}/benchmark/Sink.java | 4 ++--
.../apache/paimon}/benchmark/metric/BenchmarkMetric.java | 9 ++++-----
.../apache/paimon}/benchmark/metric/FlinkRestClient.java | 5 ++---
.../paimon}/benchmark/metric/JobBenchmarkMetric.java | 4 ++--
.../apache/paimon}/benchmark/metric/MetricReporter.java | 4 ++--
.../apache/paimon}/benchmark/metric/cpu/CpuMetric.java | 6 +++---
.../paimon}/benchmark/metric/cpu/CpuMetricReceiver.java | 6 +++---
.../paimon}/benchmark/metric/cpu/CpuMetricSender.java | 10 +++++-----
.../paimon}/benchmark/metric/cpu/CpuTimeTracker.java | 2 +-
.../paimon}/benchmark/metric/cpu/OperatingSystem.java | 2 +-
.../benchmark/metric/cpu/ProcfsBasedProcessTree.java | 7 +++----
.../benchmark/metric/cpu/ShellCommandExecutor.java | 2 +-
.../paimon}/benchmark/metric/cpu/SysInfoLinux.java | 2 +-
.../apache/paimon}/benchmark/metric/cpu/clock/Clock.java | 2 +-
.../paimon}/benchmark/metric/cpu/clock/SystemClock.java | 2 +-
.../paimon}/benchmark/utils/AutoClosableProcess.java | 2 +-
.../benchmark/utils/BenchmarkGlobalConfiguration.java | 2 +-
.../apache/paimon}/benchmark/utils/BenchmarkUtils.java | 2 +-
.../src/main/resources/bin/config.sh | 0
.../src/main/resources/bin/metric_client.sh | 0
.../src/main/resources/bin/run_benchmark.sh | 0
.../src/main/resources/bin/setup_cluster.sh | 0
.../src/main/resources/bin/shutdown_cluster.sh | 0
.../src/main/resources/conf/benchmark.yaml | 0
.../src/main/resources/conf/log4j.properties | 0
.../src/main/resources/queries/q1.sql | 0
.../src/main/resources/queries/queries.yaml | 0
.../src/main/resources/sinks/table_store.yaml | 0
.../paimon-micro-benchmarks}/pom.xml | 0
.../java/org/apache/paimon}/benchmark/Benchmark.java | 2 +-
.../org/apache/paimon}/benchmark/TableBenchmark.java | 2 +-
.../apache/paimon}/benchmark/TableWriterBenchmark.java | 2 +-
.../src/test/resources/log4j2-test.properties | 0
.../pom.xml | 4 ++--
pom.xml | 2 +-
42 files changed, 59 insertions(+), 61 deletions(-)
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/README.md b/paimon-benchmark/paimon-cluster-benchmark/README.md
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/README.md
rename to paimon-benchmark/paimon-cluster-benchmark/README.md
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/pom.xml b/paimon-benchmark/paimon-cluster-benchmark/pom.xml
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/pom.xml
rename to paimon-benchmark/paimon-cluster-benchmark/pom.xml
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/assemblies/bin.xml b/paimon-benchmark/paimon-cluster-benchmark/src/main/assemblies/bin.xml
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/assemblies/bin.xml
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/assemblies/bin.xml
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Benchmark.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java
similarity index 95%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Benchmark.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java
index 3634c5b12..efb4e70f2 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Benchmark.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Benchmark.java
@@ -16,19 +16,19 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
import org.apache.flink.configuration.Configuration;
-import org.apache.flink.table.store.benchmark.metric.FlinkRestClient;
-import org.apache.flink.table.store.benchmark.metric.JobBenchmarkMetric;
-import org.apache.flink.table.store.benchmark.metric.cpu.CpuMetricReceiver;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
import org.apache.commons.cli.CommandLine;
import org.apache.commons.cli.DefaultParser;
import org.apache.commons.cli.Option;
import org.apache.commons.cli.Options;
+import org.apache.paimon.benchmark.metric.FlinkRestClient;
+import org.apache.paimon.benchmark.metric.JobBenchmarkMetric;
+import org.apache.paimon.benchmark.metric.cpu.CpuMetricReceiver;
+import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
import java.io.File;
import java.nio.file.Path;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/BenchmarkOptions.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/BenchmarkOptions.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/BenchmarkOptions.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/BenchmarkOptions.java
index 26ff9ab0b..fca5e5245 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/BenchmarkOptions.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/BenchmarkOptions.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
import org.apache.flink.configuration.ConfigOption;
import org.apache.flink.configuration.ConfigOptions;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Query.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Query.java
similarity index 97%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Query.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Query.java
index 12b2cf17c..a231257f3 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Query.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Query.java
@@ -16,11 +16,12 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
import org.apache.flink.util.FileUtils;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
+
import java.io.IOException;
import java.nio.file.Path;
import java.util.ArrayList;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/QueryRunner.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java
similarity index 92%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/QueryRunner.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java
index 7ae2605fb..e1784ccec 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/QueryRunner.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/QueryRunner.java
@@ -16,18 +16,18 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.core.fs.FileSystem;
-import org.apache.flink.table.store.benchmark.metric.FlinkRestClient;
-import org.apache.flink.table.store.benchmark.metric.JobBenchmarkMetric;
-import org.apache.flink.table.store.benchmark.metric.MetricReporter;
-import org.apache.flink.table.store.benchmark.metric.cpu.CpuMetricReceiver;
-import org.apache.flink.table.store.benchmark.utils.AutoClosableProcess;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
+import org.apache.paimon.benchmark.metric.FlinkRestClient;
+import org.apache.paimon.benchmark.metric.JobBenchmarkMetric;
+import org.apache.paimon.benchmark.metric.MetricReporter;
+import org.apache.paimon.benchmark.metric.cpu.CpuMetricReceiver;
+import org.apache.paimon.benchmark.utils.AutoClosableProcess;
+import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Sink.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
similarity index 95%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Sink.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
index 3d31c4e68..e633bb05d 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/Sink.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/Sink.java
@@ -16,12 +16,12 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
import org.apache.flink.util.FileUtils;
import org.apache.commons.io.FilenameUtils;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
import java.io.IOException;
import java.nio.file.Files;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/BenchmarkMetric.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/BenchmarkMetric.java
similarity index 88%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/BenchmarkMetric.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/BenchmarkMetric.java
index 85f4dbb98..376fbe25b 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/BenchmarkMetric.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/BenchmarkMetric.java
@@ -16,16 +16,15 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric;
+package org.apache.paimon.benchmark.metric;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
import javax.annotation.Nullable;
/**
- * Metric collected per {@link
- * org.apache.flink.table.store.benchmark.BenchmarkOptions#METRIC_MONITOR_DURATION} for a single
- * query.
+ * Metric collected per {@link org.apache.paimon.benchmark.BenchmarkOptions#METRIC_MONITOR_DURATION}
+ * for a single query.
*/
public class BenchmarkMetric {
private final double rps;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/FlinkRestClient.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/FlinkRestClient.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java
index 73996324b..2a69e37dd 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/FlinkRestClient.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/FlinkRestClient.java
@@ -16,9 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric;
-
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
+package org.apache.paimon.benchmark.metric;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ArrayNode;
@@ -37,6 +35,7 @@ import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
import org.apache.http.util.EntityUtils;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/JobBenchmarkMetric.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/JobBenchmarkMetric.java
similarity index 95%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/JobBenchmarkMetric.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/JobBenchmarkMetric.java
index 31572b627..1cf6abad3 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/JobBenchmarkMetric.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/JobBenchmarkMetric.java
@@ -16,9 +16,9 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric;
+package org.apache.paimon.benchmark.metric;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
/** The aggregated result of a single benchmark query. */
public class JobBenchmarkMetric {
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/MetricReporter.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/MetricReporter.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/MetricReporter.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/MetricReporter.java
index 53222bfa4..1fde549f2 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/MetricReporter.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/MetricReporter.java
@@ -16,11 +16,11 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric;
+package org.apache.paimon.benchmark.metric;
import org.apache.flink.api.common.time.Deadline;
-import org.apache.flink.table.store.benchmark.metric.cpu.CpuMetricReceiver;
+import org.apache.paimon.benchmark.metric.cpu.CpuMetricReceiver;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetric.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java
similarity index 96%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetric.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java
index 1b878bc1e..bd8cb4ca4 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetric.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetric.java
@@ -16,9 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
-
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
+package org.apache.paimon.benchmark.metric.cpu;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonCreator;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.annotation.JsonIgnore;
@@ -28,6 +26,8 @@ import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessin
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ArrayNode;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
+
import javax.annotation.Nullable;
import java.util.ArrayList;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricReceiver.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricReceiver.java
similarity index 96%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricReceiver.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricReceiver.java
index 0b89836a6..947134fcc 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricReceiver.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricReceiver.java
@@ -16,12 +16,12 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
+package org.apache.paimon.benchmark.metric.cpu;
import org.apache.flink.configuration.Configuration;
-import org.apache.flink.table.store.benchmark.BenchmarkOptions;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration;
+import org.apache.paimon.benchmark.BenchmarkOptions;
+import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricSender.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricSender.java
similarity index 95%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricSender.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricSender.java
index 0c461f26b..d8d6add04 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuMetricSender.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuMetricSender.java
@@ -16,15 +16,15 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
+package org.apache.paimon.benchmark.metric.cpu;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.net.ConnectionUtils;
-import org.apache.flink.table.store.benchmark.BenchmarkOptions;
-import org.apache.flink.table.store.benchmark.utils.AutoClosableProcess;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkGlobalConfiguration;
-import org.apache.flink.table.store.benchmark.utils.BenchmarkUtils;
+import org.apache.paimon.benchmark.BenchmarkOptions;
+import org.apache.paimon.benchmark.utils.AutoClosableProcess;
+import org.apache.paimon.benchmark.utils.BenchmarkGlobalConfiguration;
+import org.apache.paimon.benchmark.utils.BenchmarkUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuTimeTracker.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuTimeTracker.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuTimeTracker.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuTimeTracker.java
index 2580a620f..12e3d75f0 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/CpuTimeTracker.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/CpuTimeTracker.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
+package org.apache.paimon.benchmark.metric.cpu;
import java.math.BigInteger;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/OperatingSystem.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/OperatingSystem.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java
index 490e02e0c..0e15ca154 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/OperatingSystem.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/OperatingSystem.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
+package org.apache.paimon.benchmark.metric.cpu;
/** An enumeration indicating the operating system that the JVM runs on. */
public enum OperatingSystem {
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ProcfsBasedProcessTree.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java
similarity index 99%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ProcfsBasedProcessTree.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java
index d790e0f63..9e685dd64 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ProcfsBasedProcessTree.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ProcfsBasedProcessTree.java
@@ -16,10 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
-
-import org.apache.flink.table.store.benchmark.metric.cpu.clock.Clock;
-import org.apache.flink.table.store.benchmark.metric.cpu.clock.SystemClock;
+package org.apache.paimon.benchmark.metric.cpu;
import org.apache.commons.io.IOUtils;
import org.apache.commons.io.filefilter.AndFileFilter;
@@ -27,6 +24,8 @@ import org.apache.commons.io.filefilter.DirectoryFileFilter;
import org.apache.commons.io.filefilter.RegexFileFilter;
import org.apache.commons.lang3.ArrayUtils;
import org.apache.commons.lang3.StringUtils;
+import org.apache.paimon.benchmark.metric.cpu.clock.Clock;
+import org.apache.paimon.benchmark.metric.cpu.clock.SystemClock;
import java.io.BufferedReader;
import java.io.File;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ShellCommandExecutor.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ShellCommandExecutor.java
similarity index 97%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ShellCommandExecutor.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ShellCommandExecutor.java
index 74b8efebf..e3abc2d34 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/ShellCommandExecutor.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/ShellCommandExecutor.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
+package org.apache.paimon.benchmark.metric.cpu;
import java.io.BufferedReader;
import java.io.IOException;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/SysInfoLinux.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java
similarity index 99%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/SysInfoLinux.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java
index 493146b72..776377589 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/SysInfoLinux.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/SysInfoLinux.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu;
+package org.apache.paimon.benchmark.metric.cpu;
import java.io.BufferedReader;
import java.io.FileInputStream;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/Clock.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/Clock.java
similarity index 96%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/Clock.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/Clock.java
index 30fb8c341..a99c9ebee 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/Clock.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/Clock.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu.clock;
+package org.apache.paimon.benchmark.metric.cpu.clock;
/**
* A clock that gives access to time. This clock returns two flavors of time:
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/SystemClock.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/SystemClock.java
similarity index 96%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/SystemClock.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/SystemClock.java
index 88b70f491..d6cec4caa 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/metric/cpu/clock/SystemClock.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/metric/cpu/clock/SystemClock.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.metric.cpu.clock;
+package org.apache.paimon.benchmark.metric.cpu.clock;
/**
* A clock that returns the time of the system / process.
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/AutoClosableProcess.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java
similarity index 99%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/AutoClosableProcess.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java
index 254ed13c2..4f79d7085 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/AutoClosableProcess.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/AutoClosableProcess.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.utils;
+package org.apache.paimon.benchmark.utils;
import org.apache.flink.api.common.time.Deadline;
import org.apache.flink.util.Preconditions;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkGlobalConfiguration.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkGlobalConfiguration.java
similarity index 99%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkGlobalConfiguration.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkGlobalConfiguration.java
index 3a38afcb2..6e3bc0ce9 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkGlobalConfiguration.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkGlobalConfiguration.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.utils;
+package org.apache.paimon.benchmark.utils;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.configuration.IllegalConfigurationException;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkUtils.java b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkUtils.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkUtils.java
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkUtils.java
index cba04d113..4dc832a61 100644
--- a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/java/org/apache/flink/table/store/benchmark/utils/BenchmarkUtils.java
+++ b/paimon-benchmark/paimon-cluster-benchmark/src/main/java/org/apache/paimon/benchmark/utils/BenchmarkUtils.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark.utils;
+package org.apache.paimon.benchmark.utils;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/config.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/config.sh
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/config.sh
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/config.sh
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/metric_client.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/metric_client.sh
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/metric_client.sh
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/metric_client.sh
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/run_benchmark.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/run_benchmark.sh
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/run_benchmark.sh
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/run_benchmark.sh
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/setup_cluster.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/setup_cluster.sh
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/setup_cluster.sh
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/setup_cluster.sh
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/bin/shutdown_cluster.sh
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/benchmark.yaml b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/benchmark.yaml
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/benchmark.yaml
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/benchmark.yaml
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/log4j.properties b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/log4j.properties
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/conf/log4j.properties
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/conf/log4j.properties
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/q1.sql b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/q1.sql
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/q1.sql
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/q1.sql
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/queries.yaml b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/queries.yaml
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/queries/queries.yaml
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/queries/queries.yaml
diff --git a/flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/sinks/table_store.yaml b/paimon-benchmark/paimon-cluster-benchmark/src/main/resources/sinks/table_store.yaml
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-cluster-benchmark/src/main/resources/sinks/table_store.yaml
rename to paimon-benchmark/paimon-cluster-benchmark/src/main/resources/sinks/table_store.yaml
diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/pom.xml b/paimon-benchmark/paimon-micro-benchmarks/pom.xml
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/pom.xml
rename to paimon-benchmark/paimon-micro-benchmarks/pom.xml
diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/Benchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/Benchmark.java
similarity index 99%
rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/Benchmark.java
rename to paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/Benchmark.java
index accae9c03..38761e7b0 100644
--- a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/Benchmark.java
+++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/Benchmark.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.SystemUtils;
diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableBenchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableBenchmark.java
similarity index 98%
rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableBenchmark.java
rename to paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableBenchmark.java
index ab426a6bb..43206ace5 100644
--- a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableBenchmark.java
+++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableBenchmark.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
import org.apache.flink.table.store.CoreOptions;
import org.apache.flink.table.store.catalog.CatalogContext;
diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableWriterBenchmark.java b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java
similarity index 99%
rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableWriterBenchmark.java
rename to paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java
index 2e8611fdb..eaeacdc19 100644
--- a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/java/org/apache/flink/table/store/benchmark/TableWriterBenchmark.java
+++ b/paimon-benchmark/paimon-micro-benchmarks/src/test/java/org/apache/paimon/benchmark/TableWriterBenchmark.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package org.apache.flink.table.store.benchmark;
+package org.apache.paimon.benchmark;
import org.apache.flink.table.store.CoreOptions;
import org.apache.flink.table.store.options.Options;
diff --git a/flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/resources/log4j2-test.properties b/paimon-benchmark/paimon-micro-benchmarks/src/test/resources/log4j2-test.properties
similarity index 100%
rename from flink-table-store-benchmark/flink-table-store-micro-benchmarks/src/test/resources/log4j2-test.properties
rename to paimon-benchmark/paimon-micro-benchmarks/src/test/resources/log4j2-test.properties
diff --git a/flink-table-store-benchmark/pom.xml b/paimon-benchmark/pom.xml
similarity index 93%
rename from flink-table-store-benchmark/pom.xml
rename to paimon-benchmark/pom.xml
index d30a5d261..c5d6cdaab 100644
--- a/flink-table-store-benchmark/pom.xml
+++ b/paimon-benchmark/pom.xml
@@ -34,8 +34,8 @@ under the License.
<packaging>pom</packaging>
<modules>
- <module>flink-table-store-cluster-benchmark</module>
- <module>flink-table-store-micro-benchmarks</module>
+ <module>paimon-cluster-benchmark</module>
+ <module>paimon-micro-benchmarks</module>
</modules>
<properties>
diff --git a/pom.xml b/pom.xml
index e9dd516ed..8b042247b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -52,7 +52,7 @@ under the License.
</scm>
<modules>
- <module>flink-table-store-benchmark</module>
+ <module>paimon-benchmark</module>
<module>flink-table-store-codegen</module>
<module>flink-table-store-codegen-loader</module>
<module>flink-table-store-common</module>