Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-16377

Fix flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • streams, unit tests
    • None

    Description

      [2024-03-13T16:07:11.125Z] Gradle Test Run :streams:test > Gradle Test Executor 95 > HighAvailabilityTaskAssignorIntegrationTest > shouldScaleOutWithWarmupTasksAndPersistentStores(String, TestInfo) > "shouldScaleOutWithWarmupTasksAndPersistentStores(String, TestInfo).balance_subtopology" FAILED
      [2024-03-13T16:07:11.125Z] java.lang.AssertionError: the first assignment after adding a node should be unstable while we warm up the state.
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest.assertFalseNoRetry(HighAvailabilityTaskAssignorIntegrationTest.java:310)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest.lambda$shouldScaleOutWithWarmupTasks$7(HighAvailabilityTaskAssignorIntegrationTest.java:237)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.test.TestUtils.lambda$waitForCondition$3(TestUtils.java:395)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:443)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:392)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:376)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:366)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasks(HighAvailabilityTaskAssignorIntegrationTest.java:232)
      [2024-03-13T16:07:11.125Z] at org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores(HighAvailabilityTaskAssignorIntegrationTest.java:130)

      https://ci-builds.apache.org/blue/rest/organizations/jenkins/pipelines/Kafka/pipelines/kafka-pr/branches/PR-15474/runs/12/nodes/9/steps/88/log/?start=0

      Attachments

        Activity

          People

            brandboat Kuan Po Tseng
            chia7712 Chia-Ping Tsai
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: