You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2025/01/31 08:48:38 UTC
(pinot) branch master updated: Adds log for failure to acquire partitionGroupConsumerSemaphore (#14955)
This is an automated email from the ASF dual-hosted git repository.
jackie 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 c4de7b7893 Adds log for failure to acquire partitionGroupConsumerSemaphore (#14955)
c4de7b7893 is described below
commit c4de7b7893e9ea5003f3d1d6ce236f7926aba68a
Author: NOOB <43...@users.noreply.github.com>
AuthorDate: Fri Jan 31 14:18:33 2025 +0530
Adds log for failure to acquire partitionGroupConsumerSemaphore (#14955)
---
.../core/data/manager/realtime/RealtimeSegmentDataManager.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
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 dbb8a6b9da..4d92624512 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
@@ -1652,7 +1652,11 @@ public class RealtimeSegmentDataManager extends SegmentDataManager {
// Acquire semaphore to create stream consumers
try {
- _partitionGroupConsumerSemaphore.acquire();
+ long startTimeMs = System.currentTimeMillis();
+ while (!_partitionGroupConsumerSemaphore.tryAcquire(5, TimeUnit.MINUTES)) {
+ _segmentLogger.warn("Failed to acquire partitionGroupConsumerSemaphore in: {} ms. Retrying.",
+ System.currentTimeMillis() - startTimeMs);
+ }
_acquiredConsumerSemaphore.set(true);
} catch (InterruptedException e) {
String errorMsg = "InterruptedException when acquiring the partitionConsumerSemaphore";
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org