MINOR: don't throw CommitFailedException during suspendTasksAndState
Author: Damian Guy
Reviewers: Matthias J. Sax, Guozhang Wang
Closes from dguy/minor-commit-failed
@@ -477,7 +477,9 @@ public class StreamThread extends Thread {
firstException.compareAndSet(null, flushAllState());
// only commit after all state has been flushed and there hasn't been an exception
if (firstException.get() == null) {
- firstException.set(commitOffsets());
+ // TODO: currently commit failures will not be thrown to users
+ // while suspending tasks; this need to be re-visit after KIP-98
+ commitOffsets();
}
// remove the changelog partitions from restore consumer
firstException.compareAndSet(null, unAssignChangeLogPartitions());
