[
https://issues.apache.org/jira/browse/KAFKA-9636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17050479#comment-17050479
]
Paul Snively edited comment on KAFKA-9636 at 3/3/20 6:54 PM:
-------------------------------------------------------------
OK, I just got the following output:
{code:java}
*** 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
{code}
As you can see, the first record correctly refers to the second. And that's
about all either of them do. But for some reason, this join still failed...
this time.
The fact that results are now nondeterministic is definitely not helping. But
thanks for yours!
was (Author: psnively):
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)
