[HUDI-7782] Task not serializable due to DynamoDBBasedLockProvider and HiveMetastoreBasedLockProvider in clean action (apache#11389)

Co-authored-by: Vova Kolmakov <[email protected]>

Author: wombatu-kun

hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProvider.java

@@ -47,6 +47,7 @@
 
 import javax.annotation.concurrent.NotThreadSafe;
 
+import java.io.Serializable;
 import java.net.URI;
 import java.util.ArrayList;
 import java.util.Collection;
@@ -58,13 +59,13 @@
  * using DynamoDB. Users need to have access to AWS DynamoDB to be able to use this lock.
  */
 @NotThreadSafe
-public class DynamoDBBasedLockProvider implements LockProvider<LockItem> {
+public class DynamoDBBasedLockProvider implements LockProvider<LockItem>, Serializable {
 
   private static final Logger LOG = LoggerFactory.getLogger(DynamoDBBasedLockProvider.class);
 
   private static final String DYNAMODB_ATTRIBUTE_NAME = "key";
 
-  private final AmazonDynamoDBLockClient client;
+  private final transient AmazonDynamoDBLockClient client;
   private final String tableName;
   private final String dynamoDBPartitionKey;
   protected final DynamoDbBasedLockConfig dynamoDBLockConfiguration;

hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java

@@ -44,6 +44,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.Serializable;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
@@ -75,18 +76,18 @@
  * using hive metastore APIs. Users need to have a HiveMetastore & Zookeeper cluster deployed to be able to use this lock.
  *
  */
-public class HiveMetastoreBasedLockProvider implements LockProvider<LockResponse> {
+public class HiveMetastoreBasedLockProvider implements LockProvider<LockResponse>, Serializable {
 
   private static final Logger LOG = LoggerFactory.getLogger(HiveMetastoreBasedLockProvider.class);
 
   private final String databaseName;
   private final String tableName;
   private final String hiveMetastoreUris;
-  private IMetaStoreClient hiveClient;
+  private transient IMetaStoreClient hiveClient;
   private volatile LockResponse lock = null;
   protected LockConfiguration lockConfiguration;
-  private ScheduledFuture<?> future = null;
-  private final ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
+  private transient ScheduledFuture<?> future = null;
+  private final transient ScheduledExecutorService executor = Executors.newScheduledThreadPool(2);
 
   public HiveMetastoreBasedLockProvider(final LockConfiguration lockConfiguration, final StorageConfiguration<?> conf) {
     this(lockConfiguration);