Address review comments #946
GitHub Actions / IntegrationTests_7 Test Reports
succeeded
Nov 22, 2025 in 1s
20 passed, 6 failed and 0 skipped
❌ IntegrationTests_7-artifacts/internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
11 tests were completed in 866s with 8 passed, 3 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing | 8✅ | 3❌ | 866s |
❌ com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing
✅ testAAIngestionWithStoreView
✅ testChangeLogConsumerSequenceId
✅ testChangelogConsumerWithNewValueSchema
✅ testNewChangelogConsumerWithNewValueSchema
✅ testSpecificRecordVeniceChangelogConsumer
❌ testVersionSpecificChangeLogConsumer
java.lang.AssertionError: expected [100] but found [0]
❌ testVersionSpecificSeekingChangeLogConsumer
java.lang.AssertionError: expected [1] but found [0]
✅ testVersionSwapInALoop
✅ testVersionSpecificChangeLogConsumer
❌ testVersionSpecificSeekingChangeLogConsumer
java.lang.AssertionError: expected [1] but found [0]
✅ testVersionSpecificSeekingChangeLogConsumer
✅ IntegrationTests_7-artifacts/internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.kafka.KafkaConsumptionTest.xml
2 tests were completed in 3s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.kafka.KafkaConsumptionTest | 2✅ | 3s |
✅ com.linkedin.venice.kafka.KafkaConsumptionTest
✅ testLocalAndRemoteConsumption[0](PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY)
✅ testLocalAndRemoteConsumption[2](STORE_AWARE_PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY)
❌ internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
11 tests were completed in 866s with 8 passed, 3 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing | 8✅ | 3❌ | 866s |
❌ com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing
✅ testAAIngestionWithStoreView
✅ testChangeLogConsumerSequenceId
✅ testChangelogConsumerWithNewValueSchema
✅ testNewChangelogConsumerWithNewValueSchema
✅ testSpecificRecordVeniceChangelogConsumer
❌ testVersionSpecificChangeLogConsumer
java.lang.AssertionError: expected [100] but found [0]
❌ testVersionSpecificSeekingChangeLogConsumer
java.lang.AssertionError: expected [1] but found [0]
✅ testVersionSwapInALoop
✅ testVersionSpecificChangeLogConsumer
❌ testVersionSpecificSeekingChangeLogConsumer
java.lang.AssertionError: expected [1] but found [0]
✅ testVersionSpecificSeekingChangeLogConsumer
✅ internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.kafka.KafkaConsumptionTest.xml
2 tests were completed in 3s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.kafka.KafkaConsumptionTest | 2✅ | 3s |
✅ com.linkedin.venice.kafka.KafkaConsumptionTest
✅ testLocalAndRemoteConsumption[0](PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY)
✅ testLocalAndRemoteConsumption[2](STORE_AWARE_PARTITION_WISE_SHARED_CONSUMER_ASSIGNMENT_STRATEGY)
Annotations
github-actions / IntegrationTests_7 Test Reports
com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing ► testVersionSpecificChangeLogConsumer
Failed test found in:
IntegrationTests_7-artifacts/internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
Error:
java.lang.AssertionError: expected [100] but found [0]
Raw output
java.lang.AssertionError: expected [100] but found [0]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:652)
at org.testng.Assert.assertEquals(Assert.java:662)
at com.linkedin.venice.consumer.TestChangelogConsumer.lambda$testVersionSpecificChangeLogConsumer$57(TestChangelogConsumer.java:1325)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:287)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:272)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:264)
at com.linkedin.venice.consumer.TestChangelogConsumer.testVersionSpecificChangeLogConsumer(TestChangelogConsumer.java:1319)
github-actions / IntegrationTests_7 Test Reports
com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing ► testVersionSpecificSeekingChangeLogConsumer
Failed test found in:
IntegrationTests_7-artifacts/internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
IntegrationTests_7-artifacts/internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
internal/venice-test-common/build/test-results/integrationTests_7/TEST-com.linkedin.venice.consumer.TestChangelogConsumerWithParallelProcessing.xml
Error:
java.lang.AssertionError: expected [1] but found [0]
Raw output
java.lang.AssertionError: expected [1] but found [0]
at org.testng.Assert.fail(Assert.java:96)
at org.testng.Assert.failNotEquals(Assert.java:776)
at org.testng.Assert.assertEqualsImpl(Assert.java:137)
at org.testng.Assert.assertEquals(Assert.java:118)
at org.testng.Assert.assertEquals(Assert.java:652)
at org.testng.Assert.assertEquals(Assert.java:662)
at com.linkedin.venice.consumer.TestChangelogConsumer.lambda$testVersionSpecificSeekingChangeLogConsumer$55(TestChangelogConsumer.java:1230)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:287)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:272)
at com.linkedin.venice.utils.TestUtils.waitForNonDeterministicAssertion(TestUtils.java:264)
at com.linkedin.venice.consumer.TestChangelogConsumer.testVersionSpecificSeekingChangeLogConsumer(TestChangelogConsumer.java:1227)
Loading