add protection to eager swap before consumer is fully subscribed #201
GitHub Actions / IntegrationTests_1410 Test Reports
succeeded
Dec 5, 2024 in 1s
136 passed, 2 failed and 0 skipped
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest.xml
2 tests were completed in 86s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest | 2✅ | 86s |
✅ com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest
✅ testParallelAdminExecutionTasks
✅ testSkipMessageEndToEnd
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor.xml
2 tests were completed in 382ms with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor | 2✅ | 382ms |
✅ com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor
✅ testCreateAndUpdatePushStrategy
✅ testSetInvalidStrategy
❌ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml
38 tests were completed in 452s with 37 passed, 1 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServer | 37✅ | 1❌ | 452s |
❌ com.linkedin.venice.controller.server.TestAdminSparkServer
✅ canCreateAHybridStore
✅ controllerCanGetDeletableStoreTopics
✅ controllerCanHandleLargePayload
✅ controllerClientCanCreateNewStore
✅ controllerClientCanDeleteAllVersion
✅ controllerClientCanDeleteOldVersion
✅ controllerClientCanDeleteStore
✅ controllerClientCanDisableStoresRead
✅ controllerClientCanDisableStoresReadWrite
✅ controllerClientCanDisableStoresWrite
✅ controllerClientCanDiscoverCluster
✅ controllerClientCanEnableMaxCapacityProtection
✅ controllerClientCanEnableThrottling
✅ controllerClientCanGetExecutionOfDeleteAllVersions
✅ controllerClientCanGetExecutionOfDeleteStore
✅ controllerClientCanGetLastSucceedExecutionId
✅ controllerClientCanGetStorageEngineOverheadRatio
❌ controllerClientCanGetStoreInfo
java.lang.AssertionError: Store from new store-version should only have one version expected [1] but found [0]
✅ controllerClientCanListFutureStoreVersions
✅ controllerClientCanListStoresStatuses
✅ controllerClientCanQueryInstanceStatusInCluster
✅ controllerClientCanQueryNodesInCluster
✅ controllerClientCanQueryRemovability
✅ controllerClientCanQueryReplicasForTopic
✅ controllerClientCanQueryReplicasOnAStorageNode
✅ controllerClientCanSetStore
✅ controllerClientCanSetStoreMetadata
✅ controllerClientCanSetStoreMissingSomeFields
✅ controllerClientCanUpdateAllowList
✅ controllerClientGetKeySchema
✅ controllerClientManageValueSchema
✅ controllerClientProvidesErrorWhenRequestingTopicForStoreThatDoesNotExist
✅ controllerClientReturns404ForNonexistentStoreQuery
✅ controllerClientSchemaOperationsAgainstInvalidStore
✅ testAggregatedHealthStatusCall
✅ testCleanupInstanceCustomizedStates
✅ testDeleteKafkaTopic
✅ controllerClientCanGetStoreInfo
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerAcl.xml
2 tests were completed in 1s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServerAcl | 2✅ | 1s |
✅ com.linkedin.venice.controller.server.TestAdminSparkServerAcl
✅ testAclRestApiException
✅ testAclRestApis
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader.xml
1 tests were completed in 467ms with 1 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader | 1✅ | 467ms |
✅ com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader
✅ testGetLeaderController
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers.xml
9 tests were completed in 16s with 9 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers | 9✅ | 16s |
✅ com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers
✅ controllerClientCanRemoveNodeFromCluster
✅ controllerClientShouldCreateStoreWithParameters
✅ controllerClientShouldCreateStoreWithParametersAndNotDeleteItIfItExists
✅ controllerClientShouldListStores
✅ controllerClientShouldSendEmptyPushAndWait
✅ endOfPushEndpointTriggersVersionSwap
✅ requestTopicIsIdempotent
✅ requestTopicIsIdempotentWithConcurrency
✅ testListStoreWithConfigFilter
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkWithMocks.xml
14 tests were completed in 3s with 14 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkWithMocks | 14✅ | 3s |
✅ com.linkedin.venice.controller.server.TestAdminSparkWithMocks
✅ testAAIncrementalPushRTSourceRegion[0](false, false)
✅ testAAIncrementalPushRTSourceRegion[1](true, false)
✅ testAAIncrementalPushRTSourceRegion[2](false, true)
✅ testAAIncrementalPushRTSourceRegion[3](true, true)
✅ testBannedRoutesAreRejected
✅ testGetRealTimeTopicUsesAdmin
✅ testSamzaReplicationPolicyMode[0](false, false, false)
✅ testSamzaReplicationPolicyMode[1](true, false, false)
✅ testSamzaReplicationPolicyMode[2](false, true, false)
✅ testSamzaReplicationPolicyMode[3](true, true, false)
✅ testSamzaReplicationPolicyMode[4](false, false, true)
✅ testSamzaReplicationPolicyMode[5](true, false, true)
✅ testSamzaReplicationPolicyMode[6](false, true, true)
✅ testSamzaReplicationPolicyMode[7](true, true, true)
✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestBackupControllerResponse.xml
1 tests were completed in 28s with 1 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestBackupControllerResponse | 1✅ | 28s |
✅ com.linkedin.venice.controller.server.TestBackupControllerResponse
✅ backupControllerThrows421
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest.xml
2 tests were completed in 86s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest | 2✅ | 86s |
✅ com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest
✅ testParallelAdminExecutionTasks
✅ testSkipMessageEndToEnd
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor.xml
2 tests were completed in 382ms with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor | 2✅ | 382ms |
✅ com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor
✅ testCreateAndUpdatePushStrategy
✅ testSetInvalidStrategy
❌ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml
38 tests were completed in 452s with 37 passed, 1 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServer | 37✅ | 1❌ | 452s |
❌ com.linkedin.venice.controller.server.TestAdminSparkServer
✅ canCreateAHybridStore
✅ controllerCanGetDeletableStoreTopics
✅ controllerCanHandleLargePayload
✅ controllerClientCanCreateNewStore
✅ controllerClientCanDeleteAllVersion
✅ controllerClientCanDeleteOldVersion
✅ controllerClientCanDeleteStore
✅ controllerClientCanDisableStoresRead
✅ controllerClientCanDisableStoresReadWrite
✅ controllerClientCanDisableStoresWrite
✅ controllerClientCanDiscoverCluster
✅ controllerClientCanEnableMaxCapacityProtection
✅ controllerClientCanEnableThrottling
✅ controllerClientCanGetExecutionOfDeleteAllVersions
✅ controllerClientCanGetExecutionOfDeleteStore
✅ controllerClientCanGetLastSucceedExecutionId
✅ controllerClientCanGetStorageEngineOverheadRatio
❌ controllerClientCanGetStoreInfo
java.lang.AssertionError: Store from new store-version should only have one version expected [1] but found [0]
✅ controllerClientCanListFutureStoreVersions
✅ controllerClientCanListStoresStatuses
✅ controllerClientCanQueryInstanceStatusInCluster
✅ controllerClientCanQueryNodesInCluster
✅ controllerClientCanQueryRemovability
✅ controllerClientCanQueryReplicasForTopic
✅ controllerClientCanQueryReplicasOnAStorageNode
✅ controllerClientCanSetStore
✅ controllerClientCanSetStoreMetadata
✅ controllerClientCanSetStoreMissingSomeFields
✅ controllerClientCanUpdateAllowList
✅ controllerClientGetKeySchema
✅ controllerClientManageValueSchema
✅ controllerClientProvidesErrorWhenRequestingTopicForStoreThatDoesNotExist
✅ controllerClientReturns404ForNonexistentStoreQuery
✅ controllerClientSchemaOperationsAgainstInvalidStore
✅ testAggregatedHealthStatusCall
✅ testCleanupInstanceCustomizedStates
✅ testDeleteKafkaTopic
✅ controllerClientCanGetStoreInfo
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerAcl.xml
2 tests were completed in 1s with 2 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServerAcl | 2✅ | 1s |
✅ com.linkedin.venice.controller.server.TestAdminSparkServerAcl
✅ testAclRestApiException
✅ testAclRestApis
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader.xml
1 tests were completed in 467ms with 1 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader | 1✅ | 467ms |
✅ com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader
✅ testGetLeaderController
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers.xml
9 tests were completed in 16s with 9 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers | 9✅ | 16s |
✅ com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers
✅ controllerClientCanRemoveNodeFromCluster
✅ controllerClientShouldCreateStoreWithParameters
✅ controllerClientShouldCreateStoreWithParametersAndNotDeleteItIfItExists
✅ controllerClientShouldListStores
✅ controllerClientShouldSendEmptyPushAndWait
✅ endOfPushEndpointTriggersVersionSwap
✅ requestTopicIsIdempotent
✅ requestTopicIsIdempotentWithConcurrency
✅ testListStoreWithConfigFilter
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkWithMocks.xml
14 tests were completed in 3s with 14 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestAdminSparkWithMocks | 14✅ | 3s |
✅ com.linkedin.venice.controller.server.TestAdminSparkWithMocks
✅ testAAIncrementalPushRTSourceRegion[0](false, false)
✅ testAAIncrementalPushRTSourceRegion[1](true, false)
✅ testAAIncrementalPushRTSourceRegion[2](false, true)
✅ testAAIncrementalPushRTSourceRegion[3](true, true)
✅ testBannedRoutesAreRejected
✅ testGetRealTimeTopicUsesAdmin
✅ testSamzaReplicationPolicyMode[0](false, false, false)
✅ testSamzaReplicationPolicyMode[1](true, false, false)
✅ testSamzaReplicationPolicyMode[2](false, true, false)
✅ testSamzaReplicationPolicyMode[3](true, true, false)
✅ testSamzaReplicationPolicyMode[4](false, false, true)
✅ testSamzaReplicationPolicyMode[5](true, false, true)
✅ testSamzaReplicationPolicyMode[6](false, true, true)
✅ testSamzaReplicationPolicyMode[7](true, true, true)
✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestBackupControllerResponse.xml
1 tests were completed in 28s with 1 passed, 0 failed and 0 skipped.
| Test suite | Passed | Failed | Skipped | Time |
|---|---|---|---|---|
| com.linkedin.venice.controller.server.TestBackupControllerResponse | 1✅ | 28s |
✅ com.linkedin.venice.controller.server.TestBackupControllerResponse
✅ backupControllerThrows421
Annotations
github-actions / IntegrationTests_1410 Test Reports
com.linkedin.venice.controller.server.TestAdminSparkServer ► controllerClientCanGetStoreInfo
Failed test found in:
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml
Error:
java.lang.AssertionError: Store from new store-version should only have one version expected [1] but found [0]
Raw output
java.lang.AssertionError: Store from new store-version should only have one version 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 com.linkedin.venice.controller.server.TestAdminSparkServer.controllerClientCanGetStoreInfo(TestAdminSparkServer.java:462)
Loading