[hudi] branch master updated: [MINOR] Fix testUpdateRejectForClustering (#6852)

[xushiyan]

This is an automated email from the ASF dual-hosted git repository.

xushiyan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 30e89d6438 [MINOR] Fix testUpdateRejectForClustering (#6852)
30e89d6438 is described below

commit 30e89d6438c7a96897040af44cf3177c8d12c248
Author: Zouxxyy <zouxinyu....@alibaba-inc.com>
AuthorDate: Mon Oct 3 13:30:30 2022 +0800

    [MINOR] Fix testUpdateRejectForClustering (#6852)
---
 .../hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java
 
b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java
index a0050b3a73..9787387a1e 100644
--- 
a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java
+++ 
b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/client/functional/TestHoodieClientOnCopyOnWriteStorage.java
@@ -1165,7 +1165,7 @@ public class TestHoodieClientOnCopyOnWriteStorage extends 
HoodieClientTestBase {
 
     // 3. insert one record with no updating reject exception, and not merge 
the small file, just generate a new file group
     String commitTime3 = "003";
-    insertBatchRecords(client, commitTime3, 1, 1).getKey();
+    insertBatchRecords(client, commitTime3, 1, 1);
     List<String> fileGroupIds2 = 
table.getFileSystemView().getAllFileGroups(testPartitionPath)
         .map(fileGroup -> 
fileGroup.getFileGroupId().getFileId()).collect(Collectors.toList());
     assertEquals(3, fileGroupIds2.size());
@@ -1178,7 +1178,7 @@ public class TestHoodieClientOnCopyOnWriteStorage extends 
HoodieClientTestBase {
     String assertMsg = String.format("Not allowed to update the clustering 
files in partition: %s "
         + "For pending clustering operations, we are not going to support 
update for now.", testPartitionPath);
     assertThrows(HoodieUpsertException.class, () -> {
-      writeClient.upsert(jsc.parallelize(insertsAndUpdates3, 1), 
commitTime3).collect(); }, assertMsg);
+      writeClient.upsert(jsc.parallelize(insertsAndUpdates3, 1), 
commitTime4).collect(); }, assertMsg);
 
     // 5. insert one record with no updating reject exception, will merge the 
small file
     String commitTime5 = "005";