Skip to content

Commit

Permalink
Minor refactoring for IDE warnings (strimzi#10692)
Browse files Browse the repository at this point in the history
Signed-off-by: Paolo Patierno <[email protected]>
  • Loading branch information
ppatierno authored Oct 10, 2024
1 parent 714df88 commit 63a2fd4
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -146,13 +146,13 @@ public class KafkaRebalanceAssemblyOperator

private static final ReconciliationLogger LOGGER = ReconciliationLogger.create(KafkaRebalanceAssemblyOperator.class.getName());

protected static final String BROKER_LOAD_KEY = "brokerLoad.json";
/* test */ static final String BROKER_LOAD_KEY = "brokerLoad.json";
private final CrdOperator<KubernetesClient, KafkaRebalance, KafkaRebalanceList> kafkaRebalanceOperator;
private final CrdOperator<KubernetesClient, Kafka, KafkaList> kafkaOperator;
private final SecretOperator secretOperations;
private final LabelSelector kafkaSelector;
private final ConfigMapOperator configMapOperator;
private int cruiseControlPort;
private final int cruiseControlPort;

/**
* @param vertx The Vertx instance
Expand Down Expand Up @@ -420,8 +420,7 @@ && rawRebalanceAnnotation(kafkaRebalance) == null) {
}

private KafkaRebalanceStatus buildRebalanceStatusFromPreviousStatus(KafkaRebalanceStatus currentStatus, Set<Condition> validation) {
List<Condition> conditions = new ArrayList<>();
conditions.addAll(validation);
List<Condition> conditions = new ArrayList<>(validation);
Condition currentState = KafkaRebalanceUtils.rebalanceStateCondition(currentStatus);
conditions.add(currentState);
return new KafkaRebalanceStatusBuilder()
Expand Down

0 comments on commit 63a2fd4

Please sign in to comment.