[Backport 2.x] implement mark() in class FilterStreamInput

[kkewwei]

Backport from #13098

[github-actions]

❌ Gradle check result for 2b4beff: FAILURE

Please examine the workflow log, locate, and copy-paste the failure(s) below, then iterate to green. Is the failure a flaky test unrelated to your change?

[github-actions]

Compatibility status:

Checks if related components are compatible with change d750c25

Incompatible components

Skipped components

Compatible components

Compatible components: [https://github.com/opensearch-project/custom-codecs.git, https://github.com/opensearch-project/flow-framework.git, https://github.com/opensearch-project/observability.git, https://github.com/opensearch-project/job-scheduler.git, https://github.com/opensearch-project/cross-cluster-replication.git, https://github.com/opensearch-project/geospatial.git, https://github.com/opensearch-project/neural-search.git, https://github.com/opensearch-project/sql.git, https://github.com/opensearch-project/k-nn.git, https://github.com/opensearch-project/security-analytics.git, https://github.com/opensearch-project/asynchronous-search.git, https://github.com/opensearch-project/notifications.git, https://github.com/opensearch-project/reporting.git, https://github.com/opensearch-project/ml-commons.git, https://github.com/opensearch-project/anomaly-detection.git, https://github.com/opensearch-project/common-utils.git, https://github.com/opensearch-project/index-management.git, https://github.com/opensearch-project/alerting.git, https://github.com/opensearch-project/security.git, https://github.com/opensearch-project/performance-analyzer-rca.git, https://github.com/opensearch-project/performance-analyzer.git]

[github-actions]

❕ Gradle check result for d750c25: UNSTABLE

• TEST FAILURES:

      1 org.opensearch.backwards.MixedClusterClientYamlTestSuiteIT.test {p0=indices.get_field_mapping/20_missing_field/Return empty object if field doesn't exist, but index does}

Please review all flaky tests that succeeded after retry and create an issue if one does not already exist to track the flaky failure.

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 71.16%. Comparing base (0dd892c) to head (d750c25).
Report is 124 commits behind head on 2.x.

Additional details and impacted files

@@             Coverage Diff              @@
##                2.x   #13145      +/-   ##
============================================
- Coverage     71.28%   71.16%   -0.12%     
- Complexity    60145    60547     +402     
============================================
  Files          4957     5000      +43     
  Lines        282799   285026    +2227     
  Branches      41409    41648     +239     
============================================
+ Hits         201591   202838    +1247     
- Misses        64189    65057     +868     
- Partials      17019    17131     +112     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[kkewwei]

❕ Gradle check result for d750c25: UNSTABLE

• TEST FAILURES:

      1 org.opensearch.backwards.MixedClusterClientYamlTestSuiteIT.test {p0=indices.get_field_mapping/20_missing_field/Return empty object if field doesn't exist, but index does}

Please review all flaky tests that succeeded after retry and create an issue if one does not already exist to track the flaky failure.

MixedClusterClientYamlTestSuiteIT.test() #2440

[kkewwei]

@reta please help review.