3 Pull requests merged by 1 person

• Fixes a regression in core where @SingleThread annotated processors are only running the last instance.

  #5902 merged Jul 25, 2025

• Links some internal documentation pages to the documentation pages

  #5703 merged Jul 25, 2025

• Adds some additional instructions for checking Maven artifacts

  #5838 merged Jul 25, 2025

6 Pull requests opened by 6 people

• Added flush remaining request for OpensearchSink on graceful shutdown

  #5888 opened Jul 21, 2025

• Fixed sorting of `includeKeys` and `excludeKeys` in `SinkModel`

  #5889 opened Jul 21, 2025

• Bump armeria + grpc + protobuf to fix CVE-2024-7254

  #5891 opened Jul 22, 2025

• Support isolation.level config for Kafka consumer

  #5894 opened Jul 23, 2025

• Updated the smoke tests scripts to use the end-to-end tests

  #5903 opened Jul 25, 2025

• [Backport 2.12] Fixes a regression in core where @SingleThread annotated processors are only running the last instance.

  #5904 opened Jul 25, 2025

4 Issues closed by 3 people

• [BUG] Service Map does not rotate with multiple workers

  #5901 closed Jul 25, 2025

• [Test Coverage] Add Test coverage for validating that events are processed exactly once by a processor

  #5690 closed Jul 24, 2025

• Set Zero Buffer as the default buffer for OpenSearch API source

  #5443 closed Jul 24, 2025

• Type conversion from json maps to json strings

  #5893 closed Jul 23, 2025

8 Issues opened by 5 people

• [BUG] LocalDBService fails to handle existing files during download

  #5899 opened Jul 24, 2025

• [BUG] S3DBService fails to handle existing files during download

  #5898 opened Jul 24, 2025

• [BUG] GeoIPProcessor creates new database manager instances on each initialization call

  #5897 opened Jul 24, 2025

• Support for Kafka consumer config: isolation.level

  #5896 opened Jul 24, 2025

• [BUG] Getting timeout on graceful Shutdown in kinesis source.

  #5895 opened Jul 24, 2025

• [BUG] Parquet output codec does not always handle byte values correctly

  #5892 opened Jul 22, 2025

• [BUG] CVE-2024-7254 in com.google.protobuf:protobuf-java (caused by com.linecorp.armeria:armeria-grpc)

  #5890 opened Jul 22, 2025

• [BUG] OpensearchSink not flushing remaining request on graceful shutdown

  #5887 opened Jul 21, 2025

4 Unresolved conversations

Sometimes conversations happen on old items that aren’t yet closed. Here is a list of all the Issues and Pull Requests with unresolved conversations.

• Introduce checkpointing per shard to DDB source, via ShardAcknowledgementManager class

  #5818 commented on Jul 25, 2025 • 12 new comments

• Make dissect processor thread-safe

  #5546 commented on Jul 21, 2025 • 0 new comments

• Support conditional script update of documents in the OpenSearch sink

  #3563 commented on Jul 24, 2025 • 0 new comments

• Initial implementation of Pipeline DLQ

  #5277 commented on Jul 21, 2025 • 0 new comments