diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java index acd1c50badbc7..8f19692ed7c72 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java @@ -20,6 +20,7 @@ import org.apache.hudi.avro.model.HoodieRollbackRequest; +import java.io.Serializable; import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -29,7 +30,7 @@ * HoodieRollbackRequest in HoodieRollbackPlan (avro pojo) is not operable direclty within spark parallel engine. * Hence converting the same to this {@link SerializableHoodieRollbackRequest} and then using it within spark.parallelize. */ -public class SerializableHoodieRollbackRequest { +public class SerializableHoodieRollbackRequest implements Serializable { private final String partitionPath; private final String fileId;