Skip to content

Merge branch 'linkedin:main' into offsetFix #582

Merge branch 'linkedin:main' into offsetFix

Merge branch 'linkedin:main' into offsetFix #582

GitHub Actions / IntegrationTests_1410 Test Reports succeeded Feb 27, 2025 in 0s

140 passed, 4 failed and 0 skipped

Tests failed

Report Passed Failed Skipped Time
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest.xml 3✅ 113s
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor.xml 2✅ 340ms
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml 38✅ 2❌ 455s
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerAcl.xml 2✅ 1s
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader.xml 1✅ 454ms
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers.xml 9✅ 14s
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkWithMocks.xml 14✅ 1s
IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestBackupControllerResponse.xml 1✅ 31s
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest.xml 3✅ 113s
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor.xml 2✅ 340ms
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServer.xml 38✅ 2❌ 455s
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerAcl.xml 2✅ 1s
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader.xml 1✅ 454ms
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers.xml 9✅ 14s
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestAdminSparkWithMocks.xml 14✅ 1s
internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.server.TestBackupControllerResponse.xml 1✅ 31s

✅ IntegrationTests_1410-artifacts/internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest.xml

3 tests were completed in 113s with 3 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest 3✅ 113s

✅ com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest

✅ testParallelAdminExecutionTasks
✅ testSkipMessageEndToEnd
✅ testUpdateAdminOperationVersion

✅ 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 340ms with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor 2✅ 340ms

✅ 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

40 tests were completed in 455s with 38 passed, 2 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkServer 38✅ 2❌ 455s

❌ 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: An error occurred during controller request. controller = http://localhost:45677, route = /store, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_8a7c0061fd_60ace4d1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 404 - Store: test-store_8a7c0061fd_60ace4d1 does not exist. expected [false] but found [true]
✅ controllerClientCanListFutureStoreVersions
✅ controllerClientCanListStoresStatuses
✅ controllerClientCanNotDeleteStore
✅ controllerClientCanQueryInstanceStatusInCluster
✅ controllerClientCanQueryNodesInCluster
✅ controllerClientCanQueryRemovability
❌ controllerClientCanQueryReplicasForTopic
	java.lang.AssertionError: An error occurred during controller request. controller = http://localhost:45677, route = /list_replicas, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_90a6b8d71d_affe1e55, version=1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 500 - Resource 'test-store_90a6b8d71d_affe1e55_v1' does not exist expected [false] but found [true]
✅ controllerClientCanQueryReplicasOnAStorageNode
✅ controllerClientCanSetStore
✅ controllerClientCanSetStoreMetadata
✅ controllerClientCanSetStoreMissingSomeFields
✅ controllerClientCanUpdateAllowList
✅ controllerClientGetKeySchema
✅ controllerClientManageValueSchema
✅ controllerClientProvidesErrorWhenRequestingTopicForStoreThatDoesNotExist
✅ controllerClientReturns404ForNonexistentStoreQuery
✅ controllerClientSchemaOperationsAgainstInvalidStore
✅ testAggregatedHealthStatusCall
✅ testCleanupInstanceCustomizedStates
✅ testDeleteKafkaTopic
✅ controllerClientCanGetStoreInfo
✅ controllerClientCanQueryReplicasForTopic

✅ 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 454ms with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader 1✅ 454ms

✅ 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 14s with 9 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers 9✅ 14s

✅ 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 1s with 14 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkWithMocks 14✅ 1s

✅ com.linkedin.venice.controller.server.TestAdminSparkWithMocks

✅ testAAIncrementalPushRTSourceRegion[0](false, false)
✅ testAAIncrementalPushRTSourceRegion[1](true, false)
✅ testAAIncrementalPushRTSourceRegion[2](false, true)
✅ testAAIncrementalPushRTSourceRegion[3](true, true)
✅ testBannedRoutesAreRejected
✅ testGetRealTimeTopicForStreamPushJobUsesAdmin
✅ 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 31s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestBackupControllerResponse 1✅ 31s

✅ 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

3 tests were completed in 113s with 3 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest 3✅ 113s

✅ com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest

✅ testParallelAdminExecutionTasks
✅ testSkipMessageEndToEnd
✅ testUpdateAdminOperationVersion

✅ internal/venice-test-common/build/test-results/integrationTests_1410/TEST-com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor.xml

2 tests were completed in 340ms with 2 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.migration.TestMigrationPushStrategyZKAccessor 2✅ 340ms

✅ 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

40 tests were completed in 455s with 38 passed, 2 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkServer 38✅ 2❌ 455s

❌ 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: An error occurred during controller request. controller = http://localhost:45677, route = /store, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_8a7c0061fd_60ace4d1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 404 - Store: test-store_8a7c0061fd_60ace4d1 does not exist. expected [false] but found [true]
✅ controllerClientCanListFutureStoreVersions
✅ controllerClientCanListStoresStatuses
✅ controllerClientCanNotDeleteStore
✅ controllerClientCanQueryInstanceStatusInCluster
✅ controllerClientCanQueryNodesInCluster
✅ controllerClientCanQueryRemovability
❌ controllerClientCanQueryReplicasForTopic
	java.lang.AssertionError: An error occurred during controller request. controller = http://localhost:45677, route = /list_replicas, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_90a6b8d71d_affe1e55, version=1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 500 - Resource 'test-store_90a6b8d71d_affe1e55_v1' does not exist expected [false] but found [true]
✅ controllerClientCanQueryReplicasOnAStorageNode
✅ controllerClientCanSetStore
✅ controllerClientCanSetStoreMetadata
✅ controllerClientCanSetStoreMissingSomeFields
✅ controllerClientCanUpdateAllowList
✅ controllerClientGetKeySchema
✅ controllerClientManageValueSchema
✅ controllerClientProvidesErrorWhenRequestingTopicForStoreThatDoesNotExist
✅ controllerClientReturns404ForNonexistentStoreQuery
✅ controllerClientSchemaOperationsAgainstInvalidStore
✅ testAggregatedHealthStatusCall
✅ testCleanupInstanceCustomizedStates
✅ testDeleteKafkaTopic
✅ controllerClientCanGetStoreInfo
✅ controllerClientCanQueryReplicasForTopic

✅ 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 454ms with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkServerGetLeader 1✅ 454ms

✅ 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 14s with 9 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkServerWithMultiServers 9✅ 14s

✅ 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 1s with 14 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestAdminSparkWithMocks 14✅ 1s

✅ com.linkedin.venice.controller.server.TestAdminSparkWithMocks

✅ testAAIncrementalPushRTSourceRegion[0](false, false)
✅ testAAIncrementalPushRTSourceRegion[1](true, false)
✅ testAAIncrementalPushRTSourceRegion[2](false, true)
✅ testAAIncrementalPushRTSourceRegion[3](true, true)
✅ testBannedRoutesAreRejected
✅ testGetRealTimeTopicForStreamPushJobUsesAdmin
✅ 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 31s with 1 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
com.linkedin.venice.controller.server.TestBackupControllerResponse 1✅ 31s

✅ com.linkedin.venice.controller.server.TestBackupControllerResponse

✅ backupControllerThrows421

Annotations

Check failure on line 443 in internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/controller/server/TestAdminSparkServer.java

See this annotation in the file changed.

@github-actions 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: An error occurred during controller request. controller = http://localhost:45677, route = /store, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_8a7c0061fd_60ace4d1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 404 - Store: test-store_8a7c0061fd_60ace4d1 does not exist. expected [false] but found [true]
Raw output
java.lang.AssertionError: An error occurred during controller request. controller = http://localhost:45677, route = /store, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_8a7c0061fd_60ace4d1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 404 - Store: test-store_8a7c0061fd_60ace4d1 does not exist. expected [false] but found [true]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertFalse(Assert.java:65)
	at com.linkedin.venice.controller.server.TestAdminSparkServer.controllerClientCanGetStoreInfo(TestAdminSparkServer.java:443)

Check failure on line 168 in internal/venice-test-common/src/integrationTest/java/com/linkedin/venice/controller/server/TestAdminSparkServer.java

See this annotation in the file changed.

@github-actions github-actions / IntegrationTests_1410 Test Reports

com.linkedin.venice.controller.server.TestAdminSparkServer ► controllerClientCanQueryReplicasForTopic

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: An error occurred during controller request. controller = http://localhost:45677, route = /list_replicas, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_90a6b8d71d_affe1e55, version=1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 500 - Resource 'test-store_90a6b8d71d_affe1e55_v1' does not exist expected [false] but found [true]
Raw output
java.lang.AssertionError: An error occurred during controller request. controller = http://localhost:45677, route = /list_replicas, params = [cluster_name=venice-cluster0, hostname=localhost, store_name=test-store_90a6b8d71d_affe1e55, version=1], timeout = 600000. Exception type: class com.linkedin.venice.exceptions.VeniceHttpException. Detailed message: Http Status 500 - Resource 'test-store_90a6b8d71d_affe1e55_v1' does not exist expected [false] but found [true]
	at org.testng.Assert.fail(Assert.java:96)
	at org.testng.Assert.failNotEquals(Assert.java:776)
	at org.testng.Assert.assertFalse(Assert.java:65)
	at com.linkedin.venice.controller.server.TestAdminSparkServer.controllerClientCanQueryReplicasForTopic(TestAdminSparkServer.java:168)