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 2021/11/02 06:17:39 UTC
[pinot] branch master updated: Clear the reused record in
PartitionUpsertMetadataManager (#7676)
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 2107b2c Clear the reused record in PartitionUpsertMetadataManager (#7676)
2107b2c is described below
commit 2107b2cd1880ec74934ec5412dbee8c874f05610
Author: Xiaotian (Jackie) Jiang <17...@users.noreply.github.com>
AuthorDate: Mon Nov 1 23:17:24 2021 -0700
Clear the reused record in PartitionUpsertMetadataManager (#7676)
---
.../pinot/segment/local/upsert/PartitionUpsertMetadataManager.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/PartitionUpsertMetadataManager.java b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/PartitionUpsertMetadataManager.java
index c4e88eb..db8ceb5 100644
--- a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/PartitionUpsertMetadataManager.java
+++ b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/PartitionUpsertMetadataManager.java
@@ -199,6 +199,7 @@ public class PartitionUpsertMetadataManager {
IndexSegment currentSegment = currentRecordLocation.getSegment();
if (_partialUpsertHandler != null) {
// Partial upsert
+ _reuse.clear();
GenericRow previousRecord = currentSegment.getRecord(currentRecordLocation.getDocId(), _reuse);
_result = _partialUpsertHandler.merge(previousRecord, record);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org