You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ya...@apache.org on 2026/10/02 17:25:10 UTC
(pinot) branch master updated: Make _numPendingOperations protected in BasePartitionUpsertMetadataManager (#19744)
This is an automated email from the ASF dual-hosted git repository.
yashmayya 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 4e27013f964 Make _numPendingOperations protected in BasePartitionUpsertMetadataManager (#19744)
4e27013f964 is described below
commit 4e27013f9647e95e1ad2a2198d9c26eda411f867
Author: Chaitanya Deepthi <45...@users.noreply.github.com>
AuthorDate: Fri Oct 2 10:25:03 2026 -0700
Make _numPendingOperations protected in BasePartitionUpsertMetadataManager (#19744)
---
.../pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
index cc2e68d0fb7..7314a72eb24 100644
--- a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
+++ b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
@@ -129,7 +129,7 @@ public abstract class BasePartitionUpsertMetadataManager implements PartitionUps
// The following variables are always accessed within synchronized block
private boolean _stopped;
// Initialize with 1 pending operation to indicate the metadata manager can take more operations
- private int _numPendingOperations = 1;
+ protected int _numPendingOperations = 1;
private boolean _closed;
// The lock and boolean flag ensure only one thread can start preloading and preloading happens only once.
private final Lock _preloadLock = new ReentrantLock();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org