You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2018/06/13 18:03:44 UTC
[kafka] branch 2.0 updated: MINOR: code cleanup follow up for
KAFKA-6906 (#5196)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.0 by this push:
new 15a44b6 MINOR: code cleanup follow up for KAFKA-6906 (#5196)
15a44b6 is described below
commit 15a44b60fd443dd037633dae22f1b0b92b3b47ad
Author: Matthias J. Sax <mj...@apache.org>
AuthorDate: Wed Jun 13 11:00:46 2018 -0700
MINOR: code cleanup follow up for KAFKA-6906 (#5196)
Reviewers: Ted Yu <yu...@gmail.com>, Guozhang Wang <gu...@confluent.io>, Bill Bejeck <bi...@confluent.io>
---
.../org/apache/kafka/streams/processor/internals/StreamTask.java | 5 -----
1 file changed, 5 deletions(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
index 805b4c0..f996958 100644
--- a/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
+++ b/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
@@ -443,11 +443,6 @@ public class StreamTask extends AbstractTask implements ProcessorNodePunctuator
transactionInFlight = true;
}
}
-
- if (eosEnabled && !startNewTransaction && transactionInFlight) { // need to make sure to commit txn for suspend case
- producer.commitTransaction();
- transactionInFlight = false;
- }
} catch (final CommitFailedException | ProducerFencedException fatal) {
throw new TaskMigratedException(this, fatal);
}
--
To stop receiving notification emails like this one, please contact
mjsax@apache.org.