From 3bf085f648fa1d263fdf3e92f8fc53ad53149beb Mon Sep 17 00:00:00 2001 From: "igor.petrenko" Date: Wed, 25 Feb 2026 08:59:53 +0200 Subject: [PATCH] fix: MemoryLoggerBackend#asRowBinary --- .../src/main/java/oap/logstream/MemoryLoggerBackend.java | 5 +---- pom.xml | 2 +- 2 files changed, 2 insertions(+), 5 deletions(-) diff --git a/oap-formats/oap-logstream/oap-logstream/src/main/java/oap/logstream/MemoryLoggerBackend.java b/oap-formats/oap-logstream/oap-logstream/src/main/java/oap/logstream/MemoryLoggerBackend.java index 72d1a41a2..1d03ee776 100644 --- a/oap-formats/oap-logstream/oap-logstream/src/main/java/oap/logstream/MemoryLoggerBackend.java +++ b/oap-formats/oap-logstream/oap-logstream/src/main/java/oap/logstream/MemoryLoggerBackend.java @@ -133,11 +133,8 @@ public List> asRowBinary( Predicate filter, String... header for( LogId id : outputs.keySet() ) { if( filter.test( id ) ) { - - String[] queryHeader = headers.length == 0 ? id.headers : headers; - ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream( outputs.getOrDefault( id, new ByteArrayOutputStream() ).toByteArray() ); - RowBinaryInputStream rowBinaryInputStream = new RowBinaryInputStream( byteArrayInputStream, queryHeader, id.types ); + RowBinaryInputStream rowBinaryInputStream = new RowBinaryInputStream( byteArrayInputStream, id.headers, id.types ); List objects; while( ( objects = rowBinaryInputStream.readRow() ) != null ) { diff --git a/pom.xml b/pom.xml index 1b2d463bd..d7247cdf6 100644 --- a/pom.xml +++ b/pom.xml @@ -57,7 +57,7 @@ - 25.4.3 + 25.4.4 25.0.1 25.0.0