IndexSet should be optional in ManyReconciler (#1200)

Netflix · Jan 6, 2022 · ae7da58 · ae7da58
1 parent 4aa4797
commit ae7da58
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...mon/src/main/java/com/netflix/titus/common/framework/simplereconciler/ManyReconciler.java b/...mon/src/main/java/com/netflix/titus/common/framework/simplereconciler/ManyReconciler.java
@@ -35,6 +35,7 @@
 import com.netflix.titus.common.util.collections.index.IndexSet;
 import com.netflix.titus.common.util.collections.index.IndexSetHolderBasic;
 import com.netflix.titus.common.util.collections.index.IndexSetHolderConcurrent;
+import com.netflix.titus.common.util.collections.index.Indexes;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.core.scheduler.Scheduler;
@@ -167,6 +168,12 @@ public Builder<DATA> withTitusRuntime(TitusRuntime titusRuntime) {
         public ManyReconciler<DATA> build() {
             Preconditions.checkNotNull(name, "Name is null");
             Preconditions.checkNotNull(titusRuntime, "TitusRuntime is null");
+
+            // Indexes are optional. If not set, provide the default value.
+            if (indexes == null) {
+                indexes = Indexes.empty();
+            }
+
             return shardCount <= 1 ? buildDefaultManyReconciler() : buildShardedManyReconciler();
         }