[
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)
