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 <[email protected]> Authored: Fri May 12 21:29:05 2017 -0700 Committer: Guozhang Wang <[email protected]> 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()));
