From 3f21e5f14c5aeda53d25416cae16f866a7e2f7f0 Mon Sep 17 00:00:00 2001 From: Sivabalan Narayanan Date: Wed, 26 Jan 2022 16:45:35 -0500 Subject: [PATCH] [MINOR] Fixing serializability of SerializableHoodieRollbackRequest (#4688) --- .../action/rollback/SerializableHoodieRollbackRequest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 acd1c50ba..8f19692ed 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 @@ package org.apache.hudi.table.action.rollback; 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 @@ import java.util.Map; * 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;