✅ testNodeReplicasReadinessCommand
✅ testRepushStoreCommand
✅ testUpdateAdminOperationVersion
✅ testUpdateClusterConfig
✅ testUpdateDarkClusterConfig
❌ testWipeClusterCommand
	org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.controller.TestAdminToolEndToEnd.testWipeClusterCommand() didn't finish within the time-out 30000
✅ testWipeClusterCommand

✅ testEnableSSLForPush

✅ deleteStoreAfterStartedPushAllowsNewPush
✅ serverRestartOnHybridStoreKeepsVersionOnline

✅ leakyTopicTruncation
✅ testAccessControl
✅ testAddAndRemoveDerivedSchema
✅ testAddMetadataSchema
✅ testAddVersionAndStartIngestionTopicCreationTimeout
✅ testAddVersionWhenClusterInMaintenanceMode
✅ testAddVersionWithRemoteKafkaBootstrapServers
✅ testAllowlist
✅ testBatchGetLimit
✅ testCannotUpdateStorePartitionNumWhenVTExists
✅ testChunkingEnabled
✅ testCloudProviderNotSet
✅ testCloudProviderSetToEmptyString
✅ testComputationEnabled
✅ testDeleteAllVersionsInStore
✅ testDeleteAllVersionsInStoreWithoutJobAndResource
✅ testDeleteOldVersionInStore
✅ testDeleteOldVersions
✅ testDeleteResourceThenRestartParticipant
✅ testDeleteStore
✅ testDeleteStoreWithLargestUsedVersionNumberOverwritten
✅ testDisableStoreRead
✅ testDisableStoreWrite
✅ testEarlyDeleteBackup
✅ testEnsureRealTimeTopicExistsForUserSystemStores
✅ testGetAndCompareStorageNodeStatusForStorageNode
✅ testGetFutureVersions
✅ testGetIncrementalPushVersion
✅ testGetNumberOfPartition
✅ testGetNumberOfPartitionsFromStoreLevelConfig
✅ testHandleVersionCreationFailure
✅ testHandleVersionCreationFailureWithCurrentVersion
✅ testHybridStoreToBatchOnly
✅ testInstanceTagging
✅ testIsLeaderController
✅ testKillOfflinePush
✅ testMultiCluster
✅ testNativeReplicationSourceFabric
✅ testNumVersionsToPreserve
✅ testRaceConditionFixForKillOfflinePushAndVersionSwap[0](false)
✅ testRaceConditionFixForKillOfflinePushAndVersionSwap[2](true)
✅ testReCreateStore
✅ testReCreateStoreWithLegacyStore
✅ testRemoveStoreFromGraveyard
✅ testRepairStoreReplicationFactor
✅ testRetireOldStoreVersionsKillOfflineFails
✅ testSetLargestUsedVersion
✅ testStartClusterAndCreatePush
✅ testStoreLevelConfigUpdateShouldNotModifyExistingVersionLevelConfig
✅ testUpdateClusterConfig
✅ testUpdateStoreMetadata
✅ testUpdateStoreWithVersionInheritedConfigs
✅ testVersionLevelActiveActiveReplicationConfig
✅ testVersionLifecycleEvents
✅ testWriteComputationEnabled

✅ testBatchOnlyDataRecoveryAPIs

✅ testDumpHostHeartbeatLag

❌ testMultipleBatchPushWithVersionCleanup
	com.linkedin.venice.exceptions.VeniceException: Could not create store store_86d920b5e7_735c1e32
✅ testMultipleBatchPushWithVersionCleanup

✅ testNativeReplicationForBatchPushWithEmergencySourceOverride[0](50, 2)

✅ testGetClusterStaleStores

✅ testFeatureFlagMultipleDC
✅ testFeatureFlagSingleDC

✅ testGetInstances
✅ testGetNumberOfPartitions
✅ testGetNumberOfPartitionsWhenResourceDropped
✅ testGetPartitions
✅ testGetQuotaExceedStores
✅ testGetReplicaStates
✅ testListeners

✅ testConvertBetweenVeniceMessageAndHelixMessage
✅ testRegisterHandler
✅ testSendMessage
✅ testSendMessageCrossingClusters
✅ testSendMessageFailed
✅ testSendMessageHandleTimeout
✅ testSendMessageRetryFailed
✅ testSendMessageRetrySuccessful
✅ testSendMessageTimeout
✅ testSendMessageToAllLiveInstances
✅ testSendMessageToNodeWithoutRegisteringHandler
✅ testSendMessageToStorageNodes

✅ testPushJobWithSaslPlaintext
✅ testPushJobWithSaslSsl

✅ testRestartRouter

✅ testBlobDiscovery

✅ testCurrentVersionLookup
✅ testD2ServiceDiscovery
✅ testRead
✅ testRequestUsageMetric
✅ testResourceStateLookup
✅ testRouterHealthCheck
✅ testHttpClient5WithoutRequestTimeout

✅ testGetProducer
✅ testGetProducerRunningFabric
✅ testSchemaMismatchError
✅ testSerialization[0](5, 10, "int")
✅ testSerialization[2](one, two, "string")
✅ testSerialization[4](6, 8, "long")
✅ testSerialization[6](9.12, 12.45, "double")
✅ testSerialization[8](1.6, 7.4, "float")
✅ testSerialization[10](java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], "bytes")
✅ testSerialization[12](true, false, "boolean")
✅ testSerializationCast[0](java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], "bytes")
✅ testSerializationCast[2](three, three, four, four, "string")
✅ testSerializationCast[4]({"int_field": 100}, {"int_field": 100}, {"int_field": 200}, {"int_field": 200}, {
  "type": "record",
  "name": "SomeRecord",
  "fields": [
     {"name": "int_field", "type": "int"}
   ]
})

✅ testThreadSafetyForPutMessages
✅ testThreadSafetyForPutMessages
✅ testThreadSafetyForPutMessages
✅ testVeniceWriterClose[0](false)
✅ testVeniceWriterClose[2](true)
✅ testVeniceWriterShouldNotCauseStackOverflow

✅ testNodeReplicasReadinessCommand
✅ testRepushStoreCommand
✅ testUpdateAdminOperationVersion
✅ testUpdateClusterConfig
✅ testUpdateDarkClusterConfig
❌ testWipeClusterCommand
	org.testng.internal.thread.ThreadTimeoutException: Method com.linkedin.venice.controller.TestAdminToolEndToEnd.testWipeClusterCommand() didn't finish within the time-out 30000
✅ testWipeClusterCommand

✅ testEnableSSLForPush

✅ deleteStoreAfterStartedPushAllowsNewPush
✅ serverRestartOnHybridStoreKeepsVersionOnline

✅ leakyTopicTruncation
✅ testAccessControl
✅ testAddAndRemoveDerivedSchema
✅ testAddMetadataSchema
✅ testAddVersionAndStartIngestionTopicCreationTimeout
✅ testAddVersionWhenClusterInMaintenanceMode
✅ testAddVersionWithRemoteKafkaBootstrapServers
✅ testAllowlist
✅ testBatchGetLimit
✅ testCannotUpdateStorePartitionNumWhenVTExists
✅ testChunkingEnabled
✅ testCloudProviderNotSet
✅ testCloudProviderSetToEmptyString
✅ testComputationEnabled
✅ testDeleteAllVersionsInStore
✅ testDeleteAllVersionsInStoreWithoutJobAndResource
✅ testDeleteOldVersionInStore
✅ testDeleteOldVersions
✅ testDeleteResourceThenRestartParticipant
✅ testDeleteStore
✅ testDeleteStoreWithLargestUsedVersionNumberOverwritten
✅ testDisableStoreRead
✅ testDisableStoreWrite
✅ testEarlyDeleteBackup
✅ testEnsureRealTimeTopicExistsForUserSystemStores
✅ testGetAndCompareStorageNodeStatusForStorageNode
✅ testGetFutureVersions
✅ testGetIncrementalPushVersion
✅ testGetNumberOfPartition
✅ testGetNumberOfPartitionsFromStoreLevelConfig
✅ testHandleVersionCreationFailure
✅ testHandleVersionCreationFailureWithCurrentVersion
✅ testHybridStoreToBatchOnly
✅ testInstanceTagging
✅ testIsLeaderController
✅ testKillOfflinePush
✅ testMultiCluster
✅ testNativeReplicationSourceFabric
✅ testNumVersionsToPreserve
✅ testRaceConditionFixForKillOfflinePushAndVersionSwap[0](false)
✅ testRaceConditionFixForKillOfflinePushAndVersionSwap[2](true)
✅ testReCreateStore
✅ testReCreateStoreWithLegacyStore
✅ testRemoveStoreFromGraveyard
✅ testRepairStoreReplicationFactor
✅ testRetireOldStoreVersionsKillOfflineFails
✅ testSetLargestUsedVersion
✅ testStartClusterAndCreatePush
✅ testStoreLevelConfigUpdateShouldNotModifyExistingVersionLevelConfig
✅ testUpdateClusterConfig
✅ testUpdateStoreMetadata
✅ testUpdateStoreWithVersionInheritedConfigs
✅ testVersionLevelActiveActiveReplicationConfig
✅ testVersionLifecycleEvents
✅ testWriteComputationEnabled

✅ testBatchOnlyDataRecoveryAPIs

✅ testDumpHostHeartbeatLag

❌ testMultipleBatchPushWithVersionCleanup
	com.linkedin.venice.exceptions.VeniceException: Could not create store store_86d920b5e7_735c1e32
✅ testMultipleBatchPushWithVersionCleanup

✅ testNativeReplicationForBatchPushWithEmergencySourceOverride[0](50, 2)

✅ testGetClusterStaleStores

✅ testFeatureFlagMultipleDC
✅ testFeatureFlagSingleDC

✅ testGetInstances
✅ testGetNumberOfPartitions
✅ testGetNumberOfPartitionsWhenResourceDropped
✅ testGetPartitions
✅ testGetQuotaExceedStores
✅ testGetReplicaStates
✅ testListeners

✅ testConvertBetweenVeniceMessageAndHelixMessage
✅ testRegisterHandler
✅ testSendMessage
✅ testSendMessageCrossingClusters
✅ testSendMessageFailed
✅ testSendMessageHandleTimeout
✅ testSendMessageRetryFailed
✅ testSendMessageRetrySuccessful
✅ testSendMessageTimeout
✅ testSendMessageToAllLiveInstances
✅ testSendMessageToNodeWithoutRegisteringHandler
✅ testSendMessageToStorageNodes

✅ testPushJobWithSaslPlaintext
✅ testPushJobWithSaslSsl

✅ testRestartRouter

✅ testBlobDiscovery

✅ testCurrentVersionLookup
✅ testD2ServiceDiscovery
✅ testRead
✅ testRequestUsageMetric
✅ testResourceStateLookup
✅ testRouterHealthCheck
✅ testHttpClient5WithoutRequestTimeout

✅ testGetProducer
✅ testGetProducerRunningFabric
✅ testSchemaMismatchError
✅ testSerialization[0](5, 10, "int")
✅ testSerialization[2](one, two, "string")
✅ testSerialization[4](6, 8, "long")
✅ testSerialization[6](9.12, 12.45, "double")
✅ testSerialization[8](1.6, 7.4, "float")
✅ testSerialization[10](java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], "bytes")
✅ testSerialization[12](true, false, "boolean")
✅ testSerializationCast[0](java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], java.nio.HeapByteBuffer[pos=0 lim=3 cap=3], "bytes")
✅ testSerializationCast[2](three, three, four, four, "string")
✅ testSerializationCast[4]({"int_field": 100}, {"int_field": 100}, {"int_field": 200}, {"int_field": 200}, {
  "type": "record",
  "name": "SomeRecord",
  "fields": [
     {"name": "int_field", "type": "int"}
   ]
})

✅ testThreadSafetyForPutMessages
✅ testThreadSafetyForPutMessages
✅ testThreadSafetyForPutMessages
✅ testVeniceWriterClose[0](false)
✅ testVeniceWriterClose[2](true)
✅ testVeniceWriterShouldNotCauseStackOverflow