Minor: set task to null at the end of shouldWrapProducerFencedExceptionWithTaskMigragedExceptionInSuspendWhenCommitting
Reviewers: Matthias J. Sax Guozhang Wang
@@ -983,6 +983,7 @@ public class StreamTaskTest {
} catch (final TaskMigratedException expected) {
assertTrue(expected.getCause() instanceof ProducerFencedException);
}
+ task = null;
assertFalse(producer.transactionCommitted());
}
