From dbec6c512b1e5a93a60034a9894e10a65db34ea4 Mon Sep 17 00:00:00 2001 From: ForwardXu Date: Wed, 15 Dec 2021 19:38:02 +0800 Subject: [PATCH] [HUDI-3022] Fix NPE for isDropPartition method (#4319) * [HUDI-3022] Fix NPE for isDropPartition method --- .../org/apache/hudi/sync/common/AbstractSyncHoodieClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/AbstractSyncHoodieClient.java b/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/AbstractSyncHoodieClient.java index 0a277bef0..98b11f2f3 100644 --- a/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/AbstractSyncHoodieClient.java +++ b/hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/AbstractSyncHoodieClient.java @@ -169,11 +169,11 @@ public abstract class AbstractSyncHoodieClient { } if (hoodieCommitMetadata.isPresent() - && hoodieCommitMetadata.get().getOperationType().equals(WriteOperationType.DELETE_PARTITION)) { + && WriteOperationType.DELETE_PARTITION.equals(hoodieCommitMetadata.get().getOperationType())) { return true; } } catch (Exception e) { - throw new HoodieSyncException("Failed to read data schema", e); + throw new HoodieSyncException("Failed to get commit metadata", e); } return false; }