@@ -689,15 +689,10 @@ private void syncShardStatsOnNewMaster(List<SnapshotsInProgress.Entry> entries)
689689 snapshot .snapshot (),
690690 shardId ,
691691 localShard .getValue ().getShardSnapshotResult (),
692- (outcomeInfoString ) -> localShard .getValue ().updateStatusDescription (
693- Strings .format ("""
694- Data node already successfully finished shard snapshot, but a new master needed to be notified. New
695- remote master notification outcome: [%s]. The prior shard snapshot status description was [%s]
696- """ ,
697- outcomeInfoString ,
698- indexShardSnapshotStatus .getStatusDescription ()
699- )
700- )
692+ (outcomeInfoString ) -> localShard .getValue ().updateStatusDescription (Strings .format ("""
693+ Data node already successfully finished shard snapshot, but a new master needed to be notified. New
694+ remote master notification outcome: [%s]. The prior shard snapshot status description was [%s]
695+ """ , outcomeInfoString , indexShardSnapshotStatus .getStatusDescription ()))
701696 );
702697 } else if (stage == Stage .FAILURE ) {
703698 // but we think the shard failed - we need to make new master know that the shard failed
@@ -715,15 +710,10 @@ private void syncShardStatsOnNewMaster(List<SnapshotsInProgress.Entry> entries)
715710 localShard .getValue ().generation (),
716711 // Update the original statusDescription with the latest remote master call outcome, but include the old
717712 // response. This will allow us to see when/whether the information reached the previous and current master.
718- (outcomeInfoString ) -> localShard .getValue ().updateStatusDescription (
719- Strings .format ("""
720- Data node already failed shard snapshot, but a new master needed to be notified. New remote master
721- notification outcome: [%s]. The prior shard snapshot status description was [%s]
722- """ ,
723- outcomeInfoString ,
724- indexShardSnapshotStatus .getStatusDescription ()
725- )
726- )
713+ (outcomeInfoString ) -> localShard .getValue ().updateStatusDescription (Strings .format ("""
714+ Data node already failed shard snapshot, but a new master needed to be notified. New remote master
715+ notification outcome: [%s]. The prior shard snapshot status description was [%s]
716+ """ , outcomeInfoString , indexShardSnapshotStatus .getStatusDescription ()))
727717 );
728718 } else if (stage == Stage .PAUSED ) {
729719 // but we think the shard has paused - we need to make new master know that
@@ -737,16 +727,10 @@ private void syncShardStatsOnNewMaster(List<SnapshotsInProgress.Entry> entries)
737727 ShardState .PAUSED_FOR_NODE_REMOVAL ,
738728 indexShardSnapshotStatus .getFailure (),
739729 localShard .getValue ().generation (),
740- (outcomeInfoString ) -> localShard .getValue ()
741- .updateStatusDescription (
742- Strings .format ("""
743- Data node already paused shard snapshot, but a new master needed to be notified. New remote
744- master notification outcome: [%s]. The prior shard snapshot status description was [%s]
745- """ ,
746- outcomeInfoString ,
747- indexShardSnapshotStatus .getStatusDescription ()
748- )
749- )
730+ (outcomeInfoString ) -> localShard .getValue ().updateStatusDescription (Strings .format ("""
731+ Data node already paused shard snapshot, but a new master needed to be notified. New remote
732+ master notification outcome: [%s]. The prior shard snapshot status description was [%s]
733+ """ , outcomeInfoString , indexShardSnapshotStatus .getStatusDescription ()))
750734 );
751735 }
752736 }
0 commit comments