Make AdjustStreamThreadCountTest#shouldResizeCacheAfterThreadReplacem…

…ent not fragile
apache · Apr 29, 2022 · b7d7b91 · b7d7b91
1 parent 137892e
commit b7d7b91
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/AdjustStreamThreadCountTest.java
@@ -471,8 +471,7 @@ public void close() {
             waitForTransitionFromRebalancingToRunning();
 
             logCaptureContext.await();
-            // after we replace the thread there should be two remaining threads with 5 bytes each for
-            // the cache and 50 for the input buffer
+            // all 10 bytes should be available for remaining thread
             assertThat(logCaptureContext.getMessages(),
                 hasItems(containsString("Adding StreamThread-3, there are now 2 threads with cache size/max buffer size values as 5/50 per thread. ")));
         }

diff --git a/...org/apache/kafka/streams/state/internals/TimeOrderedCachingPersistentWindowStoreTest.java b/...org/apache/kafka/streams/state/internals/TimeOrderedCachingPersistentWindowStoreTest.java
@@ -1130,8 +1130,7 @@ public void shouldNotThrowInvalidRangeExceptionWithNegativeFromKey() {
         final Bytes keyFrom = Bytes.wrap(Serdes.Integer().serializer().serialize("", -1));
         final Bytes keyTo = Bytes.wrap(Serdes.Integer().serializer().serialize("", 1));
 
-        try (final LogCaptureContext logCaptureContext = LogCaptureContext.create(this.getClass().getName()
-            + "#shouldNotThrowInvalidRangeExceptionWithNegativeFromKey");
+        try (final LogCaptureContext logCaptureContext = LogCaptureContext.create();
              final KeyValueIterator<Windowed<Bytes>, byte[]> iterator = cachingStore.fetch(keyFrom, keyTo, 0L, 10L)) {
             assertFalse(iterator.hasNext());
 
@@ -1151,8 +1150,7 @@ public void shouldNotThrowInvalidBackwardRangeExceptionWithNegativeFromKey() {
         final Bytes keyFrom = Bytes.wrap(Serdes.Integer().serializer().serialize("", -1));
         final Bytes keyTo = Bytes.wrap(Serdes.Integer().serializer().serialize("", 1));
 
-        try (final LogCaptureContext logCaptureContext = LogCaptureContext.create(this.getClass().getName()
-            + "#shouldNotThrowInvalidBackwardRangeExceptionWithNegativeFromKey");
+        try (final LogCaptureContext logCaptureContext = LogCaptureContext.create();
              final KeyValueIterator<Windowed<Bytes>, byte[]> iterator =
                  cachingStore.backwardFetch(keyFrom, keyTo, Instant.ofEpochMilli(0L), Instant.ofEpochMilli(10L))) {
             assertFalse(iterator.hasNext());