[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923636#comment-16923636 ] Boyang Chen commented on KAFKA-6461: [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/24606/console] > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Priority: Minor > Labels: flaky-test > Fix For: 1.1.0 > > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922907#comment-16922907 ] Matthias J. Sax commented on KAFKA-6461: [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk11/detail/kafka-trunk-jdk11/790/tests] > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Priority: Minor > Labels: flaky-test > Fix For: 1.1.0 > > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16922908#comment-16922908 ] Matthias J. Sax commented on KAFKA-6461: [https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk11/detail/kafka-trunk-jdk11/791/tests] > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Priority: Minor > Labels: flaky-test > Fix For: 1.1.0 > > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian Jira (v8.3.2#803003)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16906485#comment-16906485 ] Matthias J. Sax commented on KAFKA-6461: Different tests failed (all with caching enabled – cf. KAFKA-8078)[ https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6932/testReport/junit/org.apache.kafka.streams.integration/TableTableJoinIntegrationTest/testInnerInner_caching_enabled___true_/] and [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6932/testReport/junit/org.apache.kafka.streams.integration/TableTableJoinIntegrationTest/testInnerOuter_caching_enabled___true_/] and [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6932/testReport/junit/org.apache.kafka.streams.integration/TableTableJoinIntegrationTest/testOuterInner_caching_enabled___true_/] > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Priority: Minor > Labels: flaky-test > Fix For: 1.1.0 > > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16336529#comment-16336529 ] ASF GitHub Bot commented on KAFKA-6461: --- guozhangwang closed pull request #4451: KAFKA-6461 TableTableJoinIntegrationTest is unstable if caching is enabled URL: https://github.com/apache/kafka/pull/4451 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a foreign pull request (from a fork), the diff is supplied below (as it won't show otherwise due to GitHub magic): diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java index f3eceb09735..b5e6fcb63b9 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java @@ -79,7 +79,7 @@ public void prepareTopology() throws InterruptedException { @Override public void apply(final Long key, final String value) { numRecordsExpected++; -if (value.equals(expected)) { +if (expected.equals(value)) { boolean ret = finalResultReached.compareAndSet(false, true); if (!ret) { This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Ted Yu >Priority: Minor > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16332962#comment-16332962 ] Ted Yu commented on KAFKA-6461: --- https://github.com/apache/kafka/pull/4451 > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax >Priority: Minor > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16332922#comment-16332922 ] Matthias J. Sax commented on KAFKA-6461: That would be awesome :) > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax >Priority: Minor > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16332466#comment-16332466 ] Ted Yu commented on KAFKA-6461: --- Should I send out a PR for the above change ? > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax >Priority: Minor > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16331722#comment-16331722 ] Matthias J. Sax commented on KAFKA-6461: For me, it also passes as-is – but not always... But I agree, that {{value}} could be {{null}} – maybe it crashed if we hit a bad cache flush... > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax >Priority: Minor > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16331672#comment-16331672 ] Ted Yu commented on KAFKA-6461: --- With the following: {code} diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/TableTab index f3eceb0..5eaabbb 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java @@ -79,7 +79,7 @@ public class TableTableJoinIntegrationTest extends AbstractJoinIntegrationTest { @Override public void apply(final Long key, final String value) { numRecordsExpected++; -if (value.equals(expected)) { +if (value != null && value.equals(expected)) { boolean ret = finalResultReached.compareAndSet(false, true); if (!ret) { {code} TableTableJoinIntegrationTest passes. > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax >Priority: Minor > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled
[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16331390#comment-16331390 ] ASF GitHub Bot commented on KAFKA-6461: --- mjsax opened a new pull request #4443: KAFKA-6461: fix TableTableJoinIntegrationTest [WIP] URL: https://github.com/apache/kafka/pull/4443 DO NOT MERGE -- WIP for debugging This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > TableTableJoinIntegrationTest is unstable if caching is enabled > --- > > Key: KAFKA-6461 > URL: https://issues.apache.org/jira/browse/KAFKA-6461 > Project: Kafka > Issue Type: Improvement > Components: streams, unit tests >Reporter: Matthias J. Sax >Assignee: Matthias J. Sax >Priority: Major > > {noformat} > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest > > testLeftInner[caching enabled = true] FAILED > 20:41:05 java.lang.AssertionError: Condition not met within timeout > 15000. Never received expected final result. > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276) > 20:41:05 at > org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254) > 20:41:05 at > org.apache.kafka.streams.integration.AbstractJoinIntegrationTest.runTest(AbstractJoinIntegrationTest.java:248) > 20:41:05 at > org.apache.kafka.streams.integration.TableTableJoinIntegrationTest.testLeftInner(TableTableJoinIntegrationTest.java:313){noformat} -- This message was sent by Atlassian JIRA (v7.6.3#76005)