add changelog

Signed-off-by: kkewwei <[email protected]>
kkewwei · Apr 10, 2024 · d750c25 · d750c25
1 parent 55ccf12
commit d750c25
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -39,6 +39,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 ### Fixed
 - Fix bulk API ignores ingest pipeline for upsert ([#12883](https://github.com/opensearch-project/OpenSearch/pull/12883))
 - Fix issue with feature flags where default value may not be honored ([#12849](https://github.com/opensearch-project/OpenSearch/pull/12849))
+- Fix implement mark() and markSupported() in class FilterStreamInput ([#13098](https://github.com/opensearch-project/OpenSearch/pull/13098))
 
 ### Security
 

diff --git a/libs/core/src/test/java/org/opensearch/core/common/io/stream/FilterStreamInputTests.java b/libs/core/src/test/java/org/opensearch/core/common/io/stream/FilterStreamInputTests.java
@@ -14,6 +14,8 @@
 import java.io.IOException;
 import java.nio.ByteBuffer;
 
+import static org.hamcrest.Matchers.is;
+
 /** test the FilterStreamInput using the same BaseStreamTests */
 public class FilterStreamInputTests extends BaseStreamTests {
     @Override
@@ -34,6 +36,7 @@ public void testMarkAndReset() throws IOException {
         BytesReference bytesReference = BytesReference.fromByteBuffer(buffer);
         StreamInput streamInput = filterStreamInputTests.getStreamInput(bytesReference);
         streamInput.read();
+        assertThat(streamInput.markSupported(), is(true));
         streamInput.mark(-1);
         int int1 = streamInput.read();
         int int2 = streamInput.read();