kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 1.0 updated: HOTFIX: fix broken build
Date Sat, 27 Oct 2018 23:38:44 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a commit to branch 1.0
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/1.0 by this push:
     new 11e84e7  HOTFIX: fix broken build
11e84e7 is described below

commit 11e84e7d07e3feee8a46310962f895a273d3ed09
Author: Matthias J. Sax <matthias@confluent.io>
AuthorDate: Sat Oct 27 16:30:00 2018 -0700

    HOTFIX: fix broken build
---
 .../kafka/streams/state/internals/CachingKeyValueStoreTest.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
index ad01fea..73a080c 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
@@ -113,8 +113,8 @@ public class CachingKeyValueStoreTest extends AbstractKeyValueStoreTest
{
     public void shouldCloseAfterErrorWithFlush() {
         try {
             cache = EasyMock.niceMock(ThreadCache.class);
-            context = new InternalMockProcessorContext(null, null, null, (RecordCollector)
null, cache);
-            context.setRecordContext(new ProcessorRecordContext(10, 0, 0, topic, null));
+            context = new MockProcessorContext(null, null, null, (RecordCollector) null,
cache);
+            context.setRecordContext(new ProcessorRecordContext(10, 0, 0, topic));
             store.init(context, null);
             cache.flush("0_0-store");
             EasyMock.expectLastCall().andThrow(new NullPointerException("Simulating an error
on flush"));


Mime
View raw message