We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent efe992c commit b4f3588Copy full SHA for b4f3588
1 file changed
src/Pulsar.Client/Api/AutoClusterFailover.fs
@@ -75,7 +75,6 @@ module internal AutoClusterFailoverLogic =
75
PrimaryRecoveredTimestamp = None
76
}, AutoClusterDecision.SwitchToSecondary idx
77
| None ->
78
- Log.Logger.LogWarning("Secondary cluster is not available yet after failover delay")
79
return state, AutoClusterDecision.NoAction
80
| _ ->
81
@@ -135,6 +134,8 @@ type AutoClusterFailover
135
134
let! avail = probeAvailable secondaryServiceInfos[i].EndPointResolver
136
if avail then found <- Some i
137
i <- i + 1
+ if found.IsNone then
138
+ Log.Logger.LogWarning("Available secondary cluster wasn't found")
139
return found
140
}
141
0 commit comments