Skip to content

Commit 40abe66

Browse files
Warning message to operator log when replicas exceeds dynamic server count
1 parent 904b167 commit 40abe66

File tree

1 file changed

+24
-0
lines changed

1 file changed

+24
-0
lines changed

operator/src/main/java/oracle/kubernetes/operator/steps/ManagedServersUpStep.java

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,9 +60,22 @@ void addServerIfNeeded(@Nonnull WlsServerConfig serverConfig, WlsClusterConfig c
6060
servers.add(serverName);
6161
addStartupInfo(new ServerStartupInfo(serverConfig, clusterName, server));
6262
addToCluster(clusterName);
63+
} else {
64+
logIfReplicaExceeds(clusterConfig);
6365
}
6466
}
6567

68+
boolean exceedsMaxConfiguredClusterSize(WlsClusterConfig clusterConfig) {
69+
if (clusterConfig != null) {
70+
String clusterName = clusterConfig.getClusterName();
71+
int configClusterSize = clusterConfig.getMaxDynamicClusterSize();
72+
return clusterConfig.hasDynamicServers()
73+
&& getReplicaCount(clusterName) == configClusterSize
74+
&& domain.getReplicaCount(clusterName) > configClusterSize;
75+
}
76+
return false;
77+
}
78+
6679
private Step createNextStep(Step next) {
6780
if (servers.isEmpty()) return next;
6881
else return new ManagedServerUpIteratorStep(getStartupInfos(), next);
@@ -84,6 +97,17 @@ private void addToCluster(String clusterName) {
8497
private Integer getReplicaCount(String clusterName) {
8598
return Optional.ofNullable(replicas.get(clusterName)).orElse(0);
8699
}
100+
101+
private void logIfReplicaExceeds(WlsClusterConfig clusterConfig) {
102+
if (exceedsMaxConfiguredClusterSize(clusterConfig)) {
103+
String clusterName = clusterConfig.getClusterName();
104+
LOGGER.warning(
105+
"******* The replica count {1} exceeds the configured maximum dynamic cluster size {2} for cluster {0}",
106+
clusterName,
107+
domain.getReplicaCount(clusterName),
108+
clusterConfig.getMaxDynamicClusterSize());
109+
}
110+
}
87111
}
88112

89113
public ManagedServersUpStep(Step next) {

0 commit comments

Comments
 (0)