You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by kh...@apache.org on 2022/09/29 09:35:31 UTC
[pinot] branch master updated: fix regression due to refactoring (#9481)
This is an automated email from the ASF dual-hosted git repository.
kharekartik 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 ddc5d43119 fix regression due to refactoring (#9481)
ddc5d43119 is described below
commit ddc5d431197a5453ecdd1928cbeb4419b9f8cf3b
Author: Navina Ramesh <na...@apache.org>
AuthorDate: Thu Sep 29 15:05:20 2022 +0530
fix regression due to refactoring (#9481)
* fix regression due to refactoring
* lint fix
---
.../pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
index f20a9be217..6f59c79709 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/LLRealtimeSegmentDataManager.java
@@ -32,7 +32,6 @@ import java.util.Map;
import java.util.Set;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicLong;
import javax.annotation.Nullable;
@@ -1433,7 +1432,7 @@ public class LLRealtimeSegmentDataManager extends RealtimeSegmentDataManager {
try {
return _partitionMetadataProvider.fetchStreamPartitionOffset(OffsetCriteria.LARGEST_OFFSET_CRITERIA,
maxWaitTimeMs);
- } catch (TimeoutException e) {
+ } catch (Exception e) {
_segmentLogger.warn(
"Cannot fetch latest stream offset for clientId {} and partitionGroupId {} with maxWaitTime {}", _clientId,
_partitionGroupId, maxWaitTimeMs);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org