| commit | 237c232ad21117e76d82db253db93e86a23d302e | [log] [tgz] |
|---|---|---|
| author | YueZhang <zhangyue921010@163.com> | Thu Jun 26 09:57:55 2025 +0800 |
| committer | YueZhang <zhangyue921010@163.com> | Thu Jun 26 09:57:55 2025 +0800 |
| tree | 8a2d22d90a11efa5f1c6bfe5f603f413b412261c | |
| parent | c35fd3e42538512ed0dac606eacf19ae8ec9d491 [diff] |
fix ut
diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkBinaryCopyClusteringExecutionStrategy.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkBinaryCopyClusteringExecutionStrategy.java index 9aeded0..80d3729 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkBinaryCopyClusteringExecutionStrategy.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkBinaryCopyClusteringExecutionStrategy.java
@@ -171,7 +171,7 @@ return false; } - if (getHoodieTable().getMetaClient().getTableConfig().getBaseFileFormat().equals(PARQUET)) { + if (!getHoodieTable().getMetaClient().getTableConfig().getBaseFileFormat().equals(PARQUET)) { LOG.warn("Binary Copy only support parquet as base file format for now."); return false; }