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

Reply via email to