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/11 22:34:50 UTC
[kafka] branch 1.1 updated: MINOR: follow up cherry-pick KAFKA-6906
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 1.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/1.1 by this push:
new 128d8ea MINOR: follow up cherry-pick KAFKA-6906
128d8ea is described below
commit 128d8ea4f4023a5a9cf553d64588a512ff6dd45f
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Mon Jun 11 15:33:46 2018 -0700
MINOR: follow up cherry-pick KAFKA-6906
---
.../apache/kafka/streams/processor/internals/StreamTaskTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
index 8cd53f9..9cf2e09 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
@@ -1034,7 +1034,7 @@ public class StreamTaskTest {
@Test
public void shouldThrowOnCleanCloseTaskWhenEosEnabledIfTransactionInFlight() {
- task = createStatelessTask(createConfig(true));
+ task = createStatelessTask(true);
try {
task.close(true, false);
fail("should have throw IllegalStateException");
@@ -1049,15 +1049,15 @@ public class StreamTaskTest {
@Test
public void shouldAlwaysCommitIfEosEnabled() {
final RecordCollectorImpl recordCollector = new RecordCollectorImpl(producer, "StreamTask",
- new LogContext("StreamTaskTest "), new DefaultProductionExceptionHandler(), new Metrics().sensor("skipped-records"));
+ new LogContext("StreamTaskTest "), new DefaultProductionExceptionHandler());
- task = createStatelessTask(createConfig(true));
+ task = createStatelessTask(true);
task.initializeStateStores();
task.initializeTopology();
task.punctuate(processorSystemTime, 5, PunctuationType.WALL_CLOCK_TIME, new Punctuator() {
@Override
public void punctuate(final long timestamp) {
- recordCollector.send("result-topic1", 3, 5, null, 0, time.milliseconds(),
+ recordCollector.send("result-topic1", 3, 5, 0, time.milliseconds(),
new IntegerSerializer(), new IntegerSerializer());
}
});
--
To stop receiving notification emails like this one, please contact
mjsax@apache.org.