[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

["Josep Prat (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17360614#comment-17360614 ] 

Josep Prat commented on KAFKA-8940:
-----------------------------------

It failed again today:


{code:java}
Build / JDK 15 and Scala 2.13 / org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

java.lang.AssertionError: verifying tagg
fail: key=770 tagg=[ConsumerRecord(topic = tagg, partition = 0, leaderEpoch = 0, offset = 7, CreateTime = 1623283465319, serialized key size = 3, serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly = false), key = 770, value = 1)] expected=0
	 taggEvents: [ConsumerRecord(topic = tagg, partition = 0, leaderEpoch = 0, offset = 7, CreateTime = 1623283465319, serialized key size = 3, serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly = false), key = 770, value = 1)]
verifying suppressed min-suppressed
verifying min-suppressed with 10 keys
verifying suppressed sws-suppressed
verifying min with 10 keys
verifying max with 10 keys
verifying dif with 10 keys
verifying sum with 10 keys
verifying cnt with 10 keys
verifying avg with 10 keys
{code}


https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-10855/2/testReport/junit/org.apache.kafka.streams.integration/SmokeTestDriverIntegrationTest/Build___JDK_15_and_Scala_2_13___shouldWorkWithRebalance/
 

> Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance
> -----------------------------------------------------------------
>
>                 Key: KAFKA-8940
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8940
>             Project: Kafka
>          Issue Type: Bug
>          Components: streams, unit tests
>            Reporter: Guozhang Wang
>            Priority: Major
>              Labels: flaky-test, newbie++
>
> The test does not properly account for windowing. See this comment for full details.
> We can patch this test by fixing the timestamps of the input data to avoid crossing over a window boundary, or account for this when verifying the output. Since we have access to the input data it should be possible to compute whether/when we do cross a window boundary, and adjust the expected output accordingly



--
This message was sent by Atlassian Jira
(v8.3.4#803005)