[
https://issues.apache.org/jira/browse/KAFKA-19828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg F updated KAFKA-19828:
---------------------------
Description:
Hi,
I have a test case that contains a topology with 2 time windows and chained
emitStrategy calls. It is attached to this issue
The problem is that about 25% of the time the test fails. About 75% of the time
the test succeeds. I followed the conclusions of
Greg
was:
Hi, I got this example by using the following prompt in Google:
# kafka streams unit testing with chained "emitStrategy"
# Provide an example of testing chained suppress with different grace periods
[https://gist.github.com/gregfichtenholtz-illumio/81fb537e24f7187e9de37686bb8eca7d]
Compiled and ran the example using latest kafka jars only to get
[ERROR] Tests run: 1, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 1.103 s
<<< FAILURE! -- in com.k8sflowprocessor.ChainedEmitStrategyTopologyTest
[ERROR]
com.foo.bar.ChainedEmitStrategyTopologyTest.testChainedWindowedAggregationsWithDifferentGracePeriods
-- Time elapsed: 1.096 s <<< FAILURE!
org.opentest4j.AssertionFailedError: Final output should contain one result ==>
expected: <1> but was: <0>
at
org.junit.jupiter.api.AssertionFailureBuilder.build(AssertionFailureBuilder.java:158)
at
org.junit.jupiter.api.AssertionFailureBuilder.buildAndThrow(AssertionFailureBuilder.java:139)
at org.junit.jupiter.api.AssertEquals.failNotEqual(AssertEquals.java:201)
at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:168)
at org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:694)
at
com.foo.bar.ChainedEmitStrategyTopologyTest.testChainedWindowedAggregationsWithDifferentGracePeriods(ChainedEmitStrategyTopologyTest.java:123)
It appears that the test is not able to drive the kafka stream to emit the 2nd
event.
Could be a bug in test code/test driver/kafka streams?
Thanks in advance
Greg
> Intermittent test failures when using chained emit strategy on window close
> ---------------------------------------------------------------------------
>
> Key: KAFKA-19828
> URL: https://issues.apache.org/jira/browse/KAFKA-19828
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Reporter: Greg F
> Priority: Major
>
> Hi,
> I have a test case that contains a topology with 2 time windows and chained
> emitStrategy calls. It is attached to this issue
> The problem is that about 25% of the time the test fails. About 75% of the
> time the test succeeds. I followed the conclusions of
> Greg
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
