[HUDI-7782] Task not serializable due to DynamoDBBasedLockProvider an…

…d HiveMetastoreBasedLockProvider in clean action (#11389)

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

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