This is an automated email from the ASF dual-hosted git repository.
pratik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 4b26bf6249 Increase timeout for kafka client connection for metadata
fetch (#14638)
4b26bf6249 is described below
commit 4b26bf624965919c31a0fc6c6103ecab6531095b
Author: Pratik Tibrewal <[email protected]>
AuthorDate: Tue Dec 17 02:35:08 2024 +0530
Increase timeout for kafka client connection for metadata fetch (#14638)
---
.../pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java | 2 +-
.../java/org/apache/pinot/spi/stream/PartitionGroupMetadataFetcher.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
index de0c87e7bb..684e1ffa53 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java
@@ -1762,7 +1762,7 @@ public class RealtimeSegmentDataManager extends
SegmentDataManager {
// a single partition
// Fix this before opening support for partitioning in Kinesis
int numPartitionGroups =
_partitionMetadataProvider.computePartitionGroupMetadata(_clientId,
_streamConfig,
- Collections.emptyList(), /*maxWaitTimeMs=*/5000).size();
+ Collections.emptyList(), /*maxWaitTimeMs=*/15000).size();
if (numPartitionGroups != numPartitions) {
_segmentLogger.info(
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
index 69ad7c9ac1..98094b9e88 100644
---
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
@@ -68,7 +68,7 @@ public class PartitionGroupMetadataFetcher implements
Callable<Boolean> {
try (
StreamMetadataProvider streamMetadataProvider =
_streamConsumerFactory.createStreamMetadataProvider(clientId)) {
_newPartitionGroupMetadataList =
streamMetadataProvider.computePartitionGroupMetadata(clientId, _streamConfig,
- _partitionGroupConsumptionStatusList, /*maxWaitTimeMs=*/5000);
+ _partitionGroupConsumptionStatusList, /*maxWaitTimeMs=*/15000);
if (_exception != null) {
// We had at least one failure, but succeeded now. Log an info
LOGGER.info("Successfully retrieved PartitionGroupMetadata for topic
{}", _topicName);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
