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 <[email protected]>
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 <[email protected]>
---
.../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() {
