You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Guozhang Wang (Jira)" <ji...@apache.org> on 2019/10/17 20:30:00 UTC
[jira] [Comment Edited] (KAFKA-8940) Flaky Test
SmokeTestDriverIntegrationTest.shouldWorkWithRebalance
[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954085#comment-16954085 ]
Guozhang Wang edited comment on KAFKA-8940 at 10/17/19 8:29 PM:
----------------------------------------------------------------
{code}
java.lang.AssertionError: verifying tagg
fail: key=772 tagg=[ConsumerRecord(topic = tagg, partition = 0, leaderEpoch = 0, offset = 33, CreateTime = 1571311695362, serialized key size = 3, serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly = false), key = 772, value = 1)] expected=0
outputEvents: [ConsumerRecord(topic = tagg, partition = 0, leaderEpoch = 0, offset = 33, CreateTime = 1571311695362, serialized key size = 3, serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly = false), key = 772, 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
dif fail: key=7-1006 actual=830 expected=999
{code}
at org.junit.Assert.fail(Assert.java:89)
at org.junit.Assert.assertTrue(Assert.java:42)
at org.apache.kafka.streams.integration.SmokeTestDriverIntegrationTest.shouldWorkWithRebalance(SmokeTestDriverIntegrationTest.java:137)
was (Author: guozhang):
{code}
java.lang.AssertionError: verifying tagg
fail: key=772 tagg=[ConsumerRecord(topic = tagg, partition = 0, leaderEpoch = 0, offset = 33, CreateTime = 1571311695362, serialized key size = 3, serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly = false), key = 772, value = 1)] expected=0
outputEvents: [ConsumerRecord(topic = tagg, partition = 0, leaderEpoch = 0, offset = 33, CreateTime = 1571311695362, serialized key size = 3, serialized value size = 8, headers = RecordHeaders(headers = [], isReadOnly = false), key = 772, 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
dif fail: key=7-1006 actual=830 expected=999
{code}
> 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
> Assignee: John Roesler
> Priority: Major
> Labels: flaky-test
>
> I lost the screen shot unfortunately... it reports the set of expected records does not match the received records.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)