diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTask.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTask.java index 307c9aeceb..38222e2da7 100644 --- a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTask.java +++ b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/LeaderFollowerStoreIngestionTask.java @@ -359,7 +359,7 @@ protected void processConsumerAction(ConsumerAction message, Store store) throws * it indicates that Helix has already assigned a new role to this replica (can be leader or follower), * so quickly skip this state transition and go straight to the final transition. */ - LOGGER.info( + LOGGER.warn( "State transition from STANDBY to LEADER is skipped for replica: {}, because Helix has assigned another role to it.", Utils.getReplicaId(topicName, partition)); return; @@ -367,21 +367,21 @@ protected void processConsumerAction(ConsumerAction message, Store store) throws PartitionConsumptionState partitionConsumptionState = partitionConsumptionStateMap.get(partition); if (partitionConsumptionState == null) { - LOGGER.info( + LOGGER.warn( "State transition from STANDBY to LEADER is skipped for replica: {}, because PCS is null and the partition may have been unsubscribed.", Utils.getReplicaId(topicName, partition)); return; } if (partitionConsumptionState.getLeaderFollowerState().equals(LEADER)) { - LOGGER.info( + LOGGER.warn( "State transition from STANDBY to LEADER is skipped for replica: {} as it is already the partition leader.", Utils.getReplicaId(topicName, partition)); return; } if (store.isMigrationDuplicateStore()) { partitionConsumptionState.setLeaderFollowerState(PAUSE_TRANSITION_FROM_STANDBY_TO_LEADER); - LOGGER.info( + LOGGER.warn( "State transition from STANDBY to LEADER is paused for replica: {} as this store is undergoing migration", partitionConsumptionState.getReplicaId()); } else { @@ -400,7 +400,7 @@ protected void processConsumerAction(ConsumerAction message, Store store) throws * it indicates that Helix has already assigned a new role to this replica (can be leader or follower), * so quickly skip this state transition and go straight to the final transition. */ - LOGGER.info( + LOGGER.warn( "State transition from LEADER to STANDBY is skipped for replica: {}, because Helix has assigned another role to this replica.", Utils.getReplicaId(topicName, partition)); return; @@ -408,14 +408,14 @@ protected void processConsumerAction(ConsumerAction message, Store store) throws partitionConsumptionState = partitionConsumptionStateMap.get(partition); if (partitionConsumptionState == null) { - LOGGER.info( + LOGGER.warn( "State transition from LEADER to STANDBY is skipped for replica: {}, because PCS is null and the partition may have been unsubscribed.", Utils.getReplicaId(topicName, partition)); return; } if (partitionConsumptionState.getLeaderFollowerState().equals(STANDBY)) { - LOGGER.info( + LOGGER.warn( "State transition from LEADER to STANDBY is skipped for replica: {} as this replica is already a follower.", partitionConsumptionState.getReplicaId()); return;