This is an automated email from the ASF dual-hosted git repository. gortiz 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 0504f85bad Fix an issue while deserializing stats on error (#15991) 0504f85bad is described below commit 0504f85badbb380fbe3bdc1aa1a1a1b8cb2819c5 Author: Gonzalo Ortiz Jaureguizar <gor...@users.noreply.github.com> AuthorDate: Thu Jun 5 08:49:35 2025 +0200 Fix an issue while deserializing stats on error (#15991) --- .../org/apache/pinot/common/datablock/ZeroCopyDataBlockSerde.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pinot-common/src/main/java/org/apache/pinot/common/datablock/ZeroCopyDataBlockSerde.java b/pinot-common/src/main/java/org/apache/pinot/common/datablock/ZeroCopyDataBlockSerde.java index 265664555a..ae869b09e2 100644 --- a/pinot-common/src/main/java/org/apache/pinot/common/datablock/ZeroCopyDataBlockSerde.java +++ b/pinot-common/src/main/java/org/apache/pinot/common/datablock/ZeroCopyDataBlockSerde.java @@ -201,10 +201,10 @@ public class ZeroCopyDataBlockSerde implements DataBlockSerde { bufferView(buffer, header._variableSizeDataStart + offset, header._variableSizeDataLength)); case METADATA: { Map<Integer, String> exceptions = deserializeExceptions(stream, header); + List<DataBuffer> metadata = deserializeMetadata(buffer, header); if (!exceptions.isEmpty()) { - return MetadataBlock.newError(exceptions); + return MetadataBlock.newErrorWithStats(exceptions, metadata); } else { - List<DataBuffer> metadata = deserializeMetadata(buffer, header); return new MetadataBlock(metadata); } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org