Redistributed tests

Author: sushantmane

clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java

@@ -2370,7 +2370,7 @@ protected void processCommonConsumerAction(ConsumerAction consumerAction) throws
          */
         if (isDaVinciClient() || consumerAction.isHelixTriggeredAction()) {
           LOGGER.info(
-              "Removed replica: {} from PCS map and storage utilization manager. Trigger: {}",
+              "Removing replica: {} from PCS map and storage utilization manager. Trigger: {}",
               topicPartition,
               isDaVinciClient() ? "DaVinci client unsubscribe" : "Helix-triggered unsubscribe");
           partitionConsumptionStateMap.remove(partition);

internal/venice-test-common/build.gradle

@@ -227,6 +227,7 @@ def integrationTestBuckets = [
         "com.linkedin.venice.ingestionHeartbeat.IngestionHeartBeatTest",
         "com.linkedin.venice.endToEnd.TestPartialUpdateWithActiveActiveReplication",
         "com.linkedin.venice.controller.kafka.consumer.AdminConsumptionTaskIntegrationTest",
+        "com.linkedin.venice.controller.TestInstanceRemovable",
         "com.linkedin.venice.helix.TestHelixReadOnlyStorageEngineRepository",
         "com.linkedin.venice.helix.TestHelixReadWriteStorageEngineRepository"
     ],
@@ -245,18 +246,17 @@ def integrationTestBuckets = [
     "16": [
         "com.linkedin.venice.endToEnd.BlobP2PTransferAmongServersTest",
         "com.linkedin.venice.endToEnd.TestDaVinciRequestBasedMetaRepository",
-        "com.linkedin.venice.endToEnd.TestStoreUpdateStoragePersona",
-        "com.linkedin.venice.controller.TestInstanceRemovable",
         "com.linkedin.venice.endToEnd.DaVinciLiveUpdateSuppressionTest",
         "com.linkedin.venice.fastclient.AvroStoreClientEndToEndTest",
         "com.linkedin.venice.endToEnd.TestDeferredVersionSwapWithoutTargetedRegionPush",
         "com.linkedin.venice.controller.AdminToolE2ETest",
-        "com.linkedin.venice.router.TestStreaming",
         "com.linkedin.venice.endToEnd.TestSeparateRealtimeTopicIngestion",
         "com.linkedin.venice.fastclient.AvroStoreClientZstdEndToEndTest",
-        "com.linkedin.venice.persona.StoragePersonaAccessorTest"
+        "com.linkedin.venice.router.TestStreaming"
     ],
     "17": [
+        "com.linkedin.venice.persona.StoragePersonaAccessorTest",
+        "com.linkedin.venice.endToEnd.TestStoreUpdateStoragePersona",
         "com.linkedin.venice.endToEnd.TestProducerBatching",
         "com.linkedin.venice.hadoop.TestVenicePushJob",
         "com.linkedin.venice.router.TestRouterRetry",