vinothchandar commented on a change in pull request #4123:
URL: https://github.com/apache/hudi/pull/4123#discussion_r757625593
##########
File path:
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java
##########
@@ -584,22 +585,40 @@ public void restoreToSavepoint(String savepointTime) {
@Deprecated
public boolean rollback(final String commitInstantTime) throws
HoodieRollbackException {
- return rollback(commitInstantTime, false);
+ HoodieTable<T, I, K, O> table = createTable(config, hadoopConf);
+ Pair<HoodieInstant, HoodieRollbackPlan> pendingRollbackInfo =
getPendingRollback(table.getMetaClient(), commitInstantTime);
+ return rollback(commitInstantTime, pendingRollbackInfo,false);
}
/**
* @Deprecated
* Rollback the inflight record changes with the given commit time. This
* will be removed in future in favor of {@link
AbstractHoodieWriteClient#restoreToInstant(String)}
- *
+ * Adding this api for backwards compatability.
* @param commitInstantTime Instant time of the commit
* @param skipLocking if this is triggered by another parent transaction,
locking can be skipped.
* @throws HoodieRollbackException if rollback cannot be performed
successfully
*/
@Deprecated
public boolean rollback(final String commitInstantTime, boolean skipLocking)
throws HoodieRollbackException {
+ return rollback(commitInstantTime, null, skipLocking);
+ }
+
+ /**
+ * @Deprecated
+ * Rollback the inflight record changes with the given commit time. This
+ * will be removed in future in favor of {@link
AbstractHoodieWriteClient#restoreToInstant(String)}
+ *
+ * @param commitInstantTime Instant time of the commit
+ * @param pendingRollbackInfo pending rollback instant and plan if rollback
failed from previous attempt.
+ * @param skipLocking if this is triggered by another parent transaction,
locking can be skipped.
+ * @throws HoodieRollbackException if rollback cannot be performed
successfully
+ */
+ @Deprecated
+ public boolean rollback(final String commitInstantTime, Pair<HoodieInstant,
HoodieRollbackPlan> pendingRollbackInfo, boolean skipLocking) throws
HoodieRollbackException {
Review comment:
whats NTW?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
