This is an automated email from the ASF dual-hosted git repository. pwason pushed a commit to branch release-0.14.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 46c170425a7ac332e600941f3a06ff18f3c9aca4 Author: Amrish Lal <[email protected]> AuthorDate: Tue Sep 5 21:31:29 2023 -0700 [HUDI-6819] Fix logic for throwing exception in getRecordIndexUpdates. (#9616) * [HUDI-6819] Fix logic for throwing exception in HoodieBackedTableMetadataWriter. --- .../org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java index e99ec493558..460bfa2c6e2 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java @@ -1411,8 +1411,8 @@ public abstract class HoodieBackedTableMetadataWriter<I> implements HoodieTableM .flatMapToPair(Stream::iterator) .reduceByKey((recordDelegate1, recordDelegate2) -> { if (recordDelegate1.getRecordKey().equals(recordDelegate2.getRecordKey())) { - if (recordDelegate1.getNewLocation().isPresent() && recordDelegate2.getNewLocation().isPresent()) { - throw new HoodieIOException("Both version of records does not have location set. Record V1 " + recordDelegate1.toString() + if (!recordDelegate1.getNewLocation().isPresent() && !recordDelegate2.getNewLocation().isPresent()) { + throw new HoodieIOException("Both version of records do not have location set. Record V1 " + recordDelegate1.toString() + ", Record V2 " + recordDelegate2.toString()); } if (recordDelegate1.getNewLocation().isPresent()) {
