[ https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050479#comment-17050479 ]
Paul Snively commented on KAFKA-9636: ------------------------------------- OK, I just got the following output: {noformat} *no* further _formatting_ is done here{noformat} *** topic = TestInputTopic[topic='input-topic-1', keySerializer=StringSerializer, valueSerializer=anon$1]; key = x; record = \{"":"","p":"y"} *** *** topic = TestInputTopic[topic='input-topic-2', keySerializer=StringSerializer, valueSerializer=anon$1]; key = y; record = \{"":""} *** [info] TopologyBuilderSpec: [info] - Foreign key joins of 2-5 KTables succeeds *** FAILED *** [info] TestFailedException was thrown during property evaluation. [info] Message: TestOutputTopic[topic='output-topic', keyDeserializer=StringDeserializer, valueDeserializer=anon$2, size=0] was empty for records List(\{ [info] "" : "", [info] "p" : "y" [info] }, \{ [info] "" : "" [info] }) [info] Location: (TopologyBuilderSpec.scala:92) [info] Occurred when passed generated values ( [info] arg0 = (List(input-topic-1, input-topic-2),List(p, h),List(x, y),List(object[ -> ""], object[ -> ""]),org.apache.kafka.streams.Topology@7243da02) [info] ) [info] ScalaTest [info] Run completed in 804 milliseconds. [info] Total number of tests run: 2 [info] Suites: completed 2, aborted 0 [info] Tests: succeeded 1, failed 1, canceled 0, ignored 0, pending 0 [info] *** 1 TEST FAILED *** [error] Failed: Total 2, Failed 1, Errors 0, Passed 1 [error] Failed tests: [error] com.compstak.bottleneck.TopologyBuilderSpec > Simple join of two KTables fails > -------------------------------- > > Key: KAFKA-9636 > URL: https://issues.apache.org/jira/browse/KAFKA-9636 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 2.4.1 > Reporter: Paul Snively > Priority: Major > Attachments: kafka.tar.xz, merge_issue.zip, merge_issue.zip, > merge_issue.zip > > > Attempting to join two KTables yields a `Topology` that, when tested with > `TopologyTestDriver` by adding records to the two `TestInputTopic`s, results > in an empty `TestOutputTopic`. > I'm attaching a very small reproduction. The code is in Scala. The project is > therefore an "sbt" project. You can reproduce the results from your shell > with `sbt test`. The failure output will include the `describe` of the > `Topology` in question. -- This message was sent by Atlassian Jira (v8.3.4#803005)