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 0a277bef095b7..98b11f2f37cc4 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 boolean isDropPartition() { } 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; }