[bookkeeper] branch master updated: [ISSUE 3031] fixed test; chooseThread() uses orderingKey as a param, not a thread index (#3032)

[eolivelli]

This is an automated email from the ASF dual-hosted git repository.

eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git


The following commit(s) were added to refs/heads/master by this push:
     new 57383aa  [ISSUE 3031] fixed test; chooseThread() uses orderingKey as a 
param, not a thread index (#3032)
57383aa is described below

commit 57383aa6fe8b883275e4d4a2f9ced773d299dbb6
Author: Andrey Yegorov <8622884+dl...@users.noreply.github.com>
AuthorDate: Wed Feb 23 13:01:36 2022 -0800

    [ISSUE 3031] fixed test; chooseThread() uses orderingKey as a param, not a 
thread index (#3032)
---
 .../stream/storage/impl/store/MVCCStoreFactoryImplTest.java         | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImplTest.java
 
b/stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImplTest.java
index 616f6ad..89095de 100644
--- 
a/stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImplTest.java
+++ 
b/stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImplTest.java
@@ -147,13 +147,13 @@ public class MVCCStoreFactoryImplTest {
             assertTrue(store.spec().getKeyCoder() instanceof ByteArrayCoder);
             assertTrue(store.spec().getValCoder() instanceof ByteArrayCoder);
             assertSame(
-                factory.writeIOScheduler().chooseThread(streamId % 3),
+                factory.writeIOScheduler().chooseThread(streamId),
                 store.spec().getWriteIOScheduler());
             assertSame(
-                factory.readIOScheduler().chooseThread(streamId % 3),
+                factory.readIOScheduler().chooseThread(streamId),
                 store.spec().getReadIOScheduler());
             assertSame(
-                factory.checkpointScheduler().chooseThread(streamId % 3),
+                factory.checkpointScheduler().chooseThread(streamId),
                 store.spec().getCheckpointIOScheduler());
             assertTrue(store.spec().getCheckpointStore() instanceof 
FSCheckpointManager);
             assertEquals(Duration.ofMinutes(15), 
store.spec().getCheckpointDuration());