lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fixing serializability of SerializableHoodieRollbackRequest (#4688)

Browse Source
This commit is contained in:
Sivabalan Narayanan
2022-01-26 16:45:35 -05:00
committed by GitHub
parent f87c47352a
commit 3f21e5f14c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/SerializableHoodieRollbackRequest.java
View File

@@ -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;