[HUDI-4334] close SparkRDDWriteClient after usage in Create/Delete/RollbackSavepointsProcedure (#5994)
This commit is contained in:
@@ -68,6 +68,8 @@ class CreateSavepointsProcedure extends BaseProcedure with ProcedureBuilder with
|
||||
} catch {
|
||||
case _: HoodieSavepointException =>
|
||||
logWarning(s"Failed: Could not create savepoint $commitTime.")
|
||||
} finally {
|
||||
client.close()
|
||||
}
|
||||
|
||||
Seq(Row(result))
|
||||
|
||||
@@ -67,6 +67,8 @@ class DeleteSavepointsProcedure extends BaseProcedure with ProcedureBuilder with
|
||||
} catch {
|
||||
case _: HoodieSavepointException =>
|
||||
logWarning(s"Failed: Could not delete savepoint $instantTime.")
|
||||
} finally {
|
||||
client.close()
|
||||
}
|
||||
|
||||
Seq(Row(result))
|
||||
|
||||
@@ -67,6 +67,8 @@ class RollbackSavepointsProcedure extends BaseProcedure with ProcedureBuilder wi
|
||||
} catch {
|
||||
case _: HoodieSavepointException =>
|
||||
logWarning(s"The commit $instantTime failed to roll back.")
|
||||
} finally {
|
||||
client.close()
|
||||
}
|
||||
|
||||
Seq(Row(result))
|
||||
|
||||
Reference in New Issue
Block a user