commit eab00d570fdc986d865b511cc0402069b4b9ce2b
author Amrish Lal <amrish.k.lal@gmail.com> Tue Sep 05 21:31:29 2023 -0700
committer GitHub <noreply@github.com> Wed Sep 06 00:31:29 2023 -0400
tree e6b89387d4c5dc57f2b78e1f0c5288c538de6915
parent 48ea3cf951b728fafa03a0a98db52f4eb7d5699a

[HUDI-6819] Fix logic for throwing exception in getRecordIndexUpdates. (#9616)

* [HUDI-6819] Fix logic for throwing exception in HoodieBackedTableMetadataWriter.

hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java

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 e99ec49..460bfa2 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 @@
           .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()) {