Use mutable set

apache · Oct 9, 2023 · a4f605d · a4f605d
1 parent c131323
commit a4f605d
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java b/server/src/main/java/org/apache/druid/metadata/IndexerSQLMetadataStorageCoordinator.java
@@ -1698,11 +1698,9 @@ private SegmentIdWithShardSpec createNewSegment(
       // across all shard specs (published + pending).
       // A pending segment having a higher partitionId must also be considered
       // to avoid clashes when inserting the pending segment created here.
-      final Set<SegmentIdWithShardSpec> pendings = getPendingSegmentsForIntervalWithHandle(
-          handle,
-          dataSource,
-          interval
-      ).keySet();
+      final Set<SegmentIdWithShardSpec> pendings = new HashSet<>(
+          getPendingSegmentsForIntervalWithHandle( handle, dataSource, interval).keySet()
+      );
       if (committedMaxId != null) {
         pendings.add(committedMaxId);
       }