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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
