Take the metadata fetch time change from the HEAD

apache · Dec 17, 2024 · ab7b85b · ab7b85b
1 parent ad34f17
commit ab7b85b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/PartitionGroupMetadataFetcher.java b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/PartitionGroupMetadataFetcher.java
@@ -82,7 +82,7 @@ public Boolean call()
               streamConsumerFactory.createStreamMetadataProvider(clientId)) {
         _newPartitionGroupMetadataList.addAll(streamMetadataProvider.computePartitionGroupMetadata(clientId,
             _streamConfigs.get(i),
-            topicPartitionGroupConsumptionStatusList, /*maxWaitTimeMs=*/5000).stream().map(
+            topicPartitionGroupConsumptionStatusList, /*maxWaitTimeMs=*/15000).stream().map(
             metadata -> new PartitionGroupMetadata(
                 IngestionConfigUtils.getPinotPartitionIdFromStreamPartitionId(
                     metadata.getPartitionGroupId(), index),