You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2022/09/20 01:32:02 UTC
[hudi] branch master updated: [HUDI-4877] Fix org.apache.hudi.index.bucket.TestHoodieSimpleBucketIndex#testTagLocation not work correct issue (#6717)
This is an automated email from the ASF dual-hosted git repository.
danny0405 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 b5dc4312a4 [HUDI-4877] Fix org.apache.hudi.index.bucket.TestHoodieSimpleBucketIndex#testTagLocation not work correct issue (#6717)
b5dc4312a4 is described below
commit b5dc4312a4038e62374c6a12f601df2889cced56
Author: FocusComputing <xi...@gmail.com>
AuthorDate: Tue Sep 20 09:31:50 2022 +0800
[HUDI-4877] Fix org.apache.hudi.index.bucket.TestHoodieSimpleBucketIndex#testTagLocation not work correct issue (#6717)
Co-authored-by: xiaoxingstack <xi...@didiglobal.com>
---
.../org/apache/hudi/index/bucket/TestHoodieSimpleBucketIndex.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bucket/TestHoodieSimpleBucketIndex.java b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bucket/TestHoodieSimpleBucketIndex.java
index ea6418696c..34728c6cf3 100644
--- a/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bucket/TestHoodieSimpleBucketIndex.java
+++ b/hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/index/bucket/TestHoodieSimpleBucketIndex.java
@@ -139,7 +139,9 @@ public class TestHoodieSimpleBucketIndex extends HoodieClientTestHarness {
.filter(r -> BucketIdentifier.bucketIdFromFileId(r.getCurrentLocation().getFileId())
!= getRecordBucketId(r)).findAny().isPresent());
assertTrue(taggedRecordRDD.collectAsList().stream().filter(r -> r.getPartitionPath().equals("2015/01/31")
- && !r.isCurrentLocationKnown()).count() == 1L);
+ && !r.isCurrentLocationKnown()).count() == 1L);
+ assertTrue(taggedRecordRDD.collectAsList().stream().filter(r -> r.getPartitionPath().equals("2016/01/31")
+ && r.isCurrentLocationKnown()).count() == 3L);
}
private HoodieWriteConfig makeConfig() {