[pinot] branch master updated: Clear the reused record in PartitionUpsertMetadataManager (#7676)

[jackie]

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 <17555551+jackie-ji...@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-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org