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