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