(paimon) branch master updated: [hotfix] Fixed error words from unware to unaware. (#5599)

[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/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 247c13a383 [hotfix] Fixed error words from unware to unaware. (#5599)
247c13a383 is described below

commit 247c13a383cfc3669d33ede2b986aad6254af3a9
Author: Kerwin <37063904+zhuangch...@users.noreply.github.com>
AuthorDate: Tue May 13 23:00:57 2025 +0800

    [hotfix] Fixed error words from unware to unaware. (#5599)
---
 .../src/main/java/org/apache/paimon/schema/SchemaValidation.java  | 2 +-
 .../org/apache/paimon/flink/source/operator/MonitorSource.java    | 8 ++++----
 .../test/java/org/apache/paimon/flink/AppendOnlyTableITCase.java  | 4 ++--
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java 
b/paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java
index a0a217b39d..0300c0c30f 100644
--- a/paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java
+++ b/paimon-core/src/main/java/org/apache/paimon/schema/SchemaValidation.java
@@ -604,7 +604,7 @@ public class SchemaValidation {
             if (schema.primaryKeys().isEmpty()
                     && 
options.toMap().get(FULL_COMPACTION_DELTA_COMMITS.key()) != null) {
                 throw new RuntimeException(
-                        "AppendOnlyTable of unware or dynamic bucket does not 
support 'full-compaction.delta-commits'");
+                        "AppendOnlyTable of unaware or dynamic bucket does not 
support 'full-compaction.delta-commits'");
             }
         } else if (bucket < 1 && !isPostponeBucketTable(schema, bucket)) {
             throw new RuntimeException("The number of buckets needs to be 
greater than 0.");
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorSource.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorSource.java
index 84d6cf7dfb..e5063172ca 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorSource.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/operator/MonitorSource.java
@@ -224,8 +224,8 @@ public class MonitorSource extends 
AbstractNonCoordinatedSource<Split> {
 
         DataStream<Split> sourceDataStream =
                 bucketMode == BUCKET_UNAWARE
-                        ? shuffleUnwareBucket(singleOutputStreamOperator)
-                        : shuffleNonUnwareBucket(
+                        ? shuffleUnawareBucket(singleOutputStreamOperator)
+                        : shuffleNonUnawareBucket(
                                 singleOutputStreamOperator, 
shuffleBucketWithPartition);
 
         return sourceDataStream.transform(
@@ -234,12 +234,12 @@ public class MonitorSource extends 
AbstractNonCoordinatedSource<Split> {
                 new ReadOperator(readBuilder::newRead, 
nestedProjectedRowData));
     }
 
-    private static DataStream<Split> shuffleUnwareBucket(
+    private static DataStream<Split> shuffleUnawareBucket(
             SingleOutputStreamOperator<Split> singleOutputStreamOperator) {
         return singleOutputStreamOperator.rebalance();
     }
 
-    private static DataStream<Split> shuffleNonUnwareBucket(
+    private static DataStream<Split> shuffleNonUnawareBucket(
             SingleOutputStreamOperator<Split> singleOutputStreamOperator,
             boolean shuffleBucketWithPartition) {
         return singleOutputStreamOperator.partitionCustom(
diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendOnlyTableITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendOnlyTableITCase.java
index e18688bdd7..e73faa764e 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendOnlyTableITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/AppendOnlyTableITCase.java
@@ -68,7 +68,7 @@ public class AppendOnlyTableITCase extends CatalogITCaseBase {
                                                 + "WITH ('bucket' = 
'-1','full-compaction.delta-commits'='10')"))
                 .hasRootCauseInstanceOf(RuntimeException.class)
                 .hasRootCauseMessage(
-                        "AppendOnlyTable of unware or dynamic bucket does not 
support 'full-compaction.delta-commits'");
+                        "AppendOnlyTable of unaware or dynamic bucket does not 
support 'full-compaction.delta-commits'");
     }
 
     @Test
@@ -257,7 +257,7 @@ public class AppendOnlyTableITCase extends 
CatalogITCaseBase {
     }
 
     @Test
-    public void testReadUnwareBucketTableWithRebalanceShuffle() throws 
Exception {
+    public void testReadUnawareBucketTableWithRebalanceShuffle() throws 
Exception {
         batchSql(
                 "CREATE TABLE append_scalable_table (id INT, data STRING) "
                         + "WITH ('bucket' = '-1', 'consumer-id' = 'test', 
'consumer.expiration-time' = '365 d', 'target-file-size' = '1 B', 
'source.split.target-size' = '1 B', 'scan.parallelism' = '4')");