kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: HOTFIX: convert Bytes back to byte[] in MergedSortedCacheWindowStoreIteratorTest
Date Sat, 13 May 2017 04:29:15 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 b9fc41f04 -> 8bf70610b


HOTFIX: convert Bytes back to byte[] in MergedSortedCacheWindowStoreIteratorTest


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8bf70610
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8bf70610
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8bf70610

Branch: refs/heads/0.10.2
Commit: 8bf70610ba818f2d8e38fd285e553994d4e0d4b2
Parents: b9fc41f
Author: Guozhang Wang <wangguoz@gmail.com>
Authored: Fri May 12 21:29:05 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Fri May 12 21:29:05 2017 -0700

----------------------------------------------------------------------
 .../internals/MergedSortedCacheWindowStoreIteratorTest.java      | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8bf70610/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIteratorTest.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIteratorTest.java
b/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIteratorTest.java
index f209632..2bc2ee2 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIteratorTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/MergedSortedCacheWindowStoreIteratorTest.java
@@ -89,8 +89,8 @@ public class MergedSortedCacheWindowStoreIteratorTest {
     public void shouldPeekNextCacheKey() throws Exception {
         windowStoreKvPairs.add(KeyValue.pair(0L, "a".getBytes()));
         cache.put(namespace, WindowStoreUtils.toBinaryKey("a", 10L, 0, stateSerdes), new
LRUCacheEntry("b".getBytes()));
-        Bytes fromBytes = WindowStoreUtils.toBinaryKey("a", 0, 0, stateSerdes);
-        Bytes toBytes = WindowStoreUtils.toBinaryKey("a", 100, 0, stateSerdes);
+        byte[] fromBytes = WindowStoreUtils.toBinaryKey("a", 0, 0, stateSerdes);
+        byte[] toBytes = WindowStoreUtils.toBinaryKey("a", 100, 0, stateSerdes);
         final KeyValueIterator<Long, byte[]> storeIterator = new DelegatingPeekingKeyValueIterator<>("store",
new KeyValueIteratorStub<>(windowStoreKvPairs.iterator()));
         final ThreadCache.MemoryLRUCacheBytesIterator cacheIterator = cache.range(namespace,
fromBytes, toBytes);
         final MergedSortedCacheWindowStoreIterator<byte[]> iterator = new MergedSortedCacheWindowStoreIterator<>(cacheIterator,
storeIterator, new StateSerdes<>("name", Serdes.Long(), Serdes.ByteArray()));


Mime
View raw message