remove validateRemoteHybridSettings, no longer needed

Author: pthirun

clients/venice-push-job/src/main/java/com/linkedin/venice/hadoop/VenicePushJob.java

@@ -762,7 +762,6 @@ public void run() {
       HadoopUtils.createDirectoryWithPermission(sharedTmpDir, PERMISSION_777);
       HadoopUtils.createDirectoryWithPermission(jobTmpDir, PERMISSION_700);
       pushJobSetting.newKmeSchemasFromController = validateAndFetchNewKafkaMessageEnvelopeSchemas(pushJobSetting);
-      validateRemoteHybridSettings(pushJobSetting);
       validateStoreSettingAndPopulate(controllerClient, pushJobSetting);
       inputStorageQuotaTracker = new InputStorageQuotaTracker(pushJobSetting.storeStorageQuota);
 
@@ -2031,15 +2030,6 @@ void validateKeySchema(PushJobSetting setting) {
     }
   }
 
-  protected void validateRemoteHybridSettings() {
-    validateRemoteHybridSettings(pushJobSetting);
-  }
-
-  protected void validateRemoteHybridSettings(PushJobSetting setting) {
-    // No-op: With epoch passthrough, the absolute epoch timestamp flows directly through the
-    // pipeline, making the SOP/EOP replay policy validation unnecessary.
-  }
-
   private Map<Integer, String> validateAndFetchNewKafkaMessageEnvelopeSchemas(PushJobSetting setting) {
     // Obtain the highest schema for KME from controller
     int localHighestKmeSchemaId = AvroProtocolDefinition.KAFKA_MESSAGE_ENVELOPE.getCurrentProtocolVersion();

clients/venice-push-job/src/test/java/com/linkedin/venice/hadoop/TestKafkaFormatTopicAutoDiscover.java

@@ -4,7 +4,6 @@
 import static com.linkedin.venice.vpj.VenicePushJobConstants.D2_ZK_HOSTS_PREFIX;
 import static com.linkedin.venice.vpj.VenicePushJobConstants.KAFKA_INPUT_BROKER_URL;
 import static com.linkedin.venice.vpj.VenicePushJobConstants.KAFKA_INPUT_TOPIC;
-import static com.linkedin.venice.vpj.VenicePushJobConstants.REWIND_EPOCH_TIME_IN_SECONDS_OVERRIDE;
 import static com.linkedin.venice.vpj.VenicePushJobConstants.SOURCE_GRID_FABRIC;
 import static com.linkedin.venice.vpj.VenicePushJobConstants.SOURCE_KAFKA;
 import static com.linkedin.venice.vpj.VenicePushJobConstants.SSL_KEY_PASSWORD_PROPERTY_NAME;
@@ -65,28 +64,6 @@ public void testNoUserProvidedTopicNameAndSingleColoVersion() {
     }
   }
 
-  @Test
-  public void testUserProvidedEpochRewind() {
-    final int singleColoCurrentVersion = 1;
-    ControllerClient controllerClient = mock(ControllerClient.class);
-    Map<String, Integer> coloToVersionMap = Collections.emptyMap();
-    StoreResponse storeResponse =
-        getMockHybridStoreResponse(coloToVersionMap, singleColoCurrentVersion, BufferReplayPolicy.REWIND_FROM_SOP);
-    when(controllerClient.getStore(STORE_NAME)).thenReturn(storeResponse);
-    RepushInfoResponse repushInfo = getMockRepushResponse(1);
-    when(controllerClient.getRepushInfo(STORE_NAME, Optional.empty())).thenReturn(repushInfo);
-    configureClusterDiscoveryControllerClient(controllerClient);
-    Map<String, String> overrideProperties = new HashMap<>();
-    overrideProperties.put(VENICE_STORE_NAME_PROP, STORE_NAME);
-    overrideProperties.put(REWIND_EPOCH_TIME_IN_SECONDS_OVERRIDE, "1637016606");
-    try (VenicePushJob venicePushJob = new VenicePushJob(JOB_ID, getJobProperties(overrideProperties))) {
-      venicePushJob.setControllerClient(controllerClient);
-      venicePushJob.initKIFRepushDetails();
-      venicePushJob.setControllerClient(controllerClient);
-      venicePushJob.validateRemoteHybridSettings();
-    }
-  }
-
   @Test
   public void testNoUserProvidedTopicNameAndMultiColoVersion() {
     final int multipleColoCurrentVersion = 1;