mjsax commented on code in PR #13533:
URL: https://github.com/apache/kafka/pull/13533#discussion_r1175716345
##########
streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java:
##########
@@ -543,6 +543,16 @@ public void
shouldAllowRemovingAndAddingNamedTopologyToRunningApplicationWithMul
@Test
public void shouldRemoveOneNamedTopologyWhileAnotherContinuesProcessing()
throws Exception {
+ /*
+ Gradle Test Run :streams:unitTest > Gradle Test Executor 19 >
NamedTopologyIntegrationTest >
shouldRemoveOneNamedTopologyWhileAnotherContinuesProcessing() FAILED
+ java.lang.AssertionError:
+ Expected: <[KeyValue(B, 1), KeyValue(A, 2), KeyValue(C, 2)]>
+ but: was <[KeyValue(B, 1), KeyValue(A, 2), KeyValue(C, 1)]>
+ at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
+ at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:6)
+ at
org.apache.kafka.streams.integration.NamedTopologyIntegrationTest.shouldRemoveOneNamedTopologyWhileAnotherContinuesProcessing(NamedTopologyIntegrationTest.java:563)
+
+ */
Review Comment:
Ups. This should not go into this PR. Good catch.
The test is flaky and it was not to myself for my local copy only.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
