feat(streaming): state clean for eowc over window numbering functions (#24477)

ci: run pubsub emulator via docker (#25238)

fix(source): eliminate checkpoint-path network I/O and add ack failure metrics (#25144)

fix(sink): handle postgres upsert when all columns are primary keys (#25253)

fix(sink): fix file sink name conflict issue (#25241)

fix(batch): fix batch asof join (#25223)

fix(metric): fix several grafana panels (#25232)

refactor(meta): unify barrier completion flow to partial-graph manager (#25157)

feat(sink): support limiting the max concurrent initializing kv log store reader (#25224)

fix: iceberg e2e test when default to use datafusion (#25215)

feat(source): adaptive splits + streaming pull for PubSub source (#25074)

fix(meta): load fragment parallelism from meta store table directly (#25220)

feat(object-store): support limit the opendal req concurrency (#25222)

refactor(meta): unify barrier item collection for partial graphs and finishing jobs (#25219)

feat(stream): make join_cache_evict_interval_rows configurable (#25210)