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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
