Browse Source

Minor: set task to null at the end of shouldWrapProducerFencedExceptionWithTaskMigragedExceptionInSuspendWhenCommitting (#5534)

Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <guozhang@confluent.io>
pull/5555/head
tedyu 6 years ago committed by Matthias J. Sax
parent
commit
3afcbebf39
  1. 1
      streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java

1
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java

@ -983,6 +983,7 @@ public class StreamTaskTest {
} catch (final TaskMigratedException expected) { } catch (final TaskMigratedException expected) {
assertTrue(expected.getCause() instanceof ProducerFencedException); assertTrue(expected.getCause() instanceof ProducerFencedException);
} }
task = null;
assertFalse(producer.transactionCommitted()); assertFalse(producer.transactionCommitted());
} }

Loading…
Cancel
Save