Repository Issue Activity (beta)

#12061 [Improve][Zeta] Investigate and improve IMap job-storage benchmark stability

#12124 [Improve][Zeta] Add a JobStatus ordinal guard test and replace ordinal comparisons with explicit state sets

#12154 [Feature][Docs] Improve engine support and FAQ documentation for RabbitMQ, Milvus, and Email connectors

#12139 [Bug][Zeta] Pipeline restore hangs forever when the source enumerator cannot be created during restoreState (PaimonIT privilege test, 3-hour CI job)

#12145 [Feature][Benchmark] Add open-loop MultiTableSinkWriter benchmarks

#11364 [STIP-30][Feature][CDC] : Unified CDC lag and progress observability model

#12087 [STIP-37][Feature][Zeta] Add autoscaling support for SeaTunnel Engine worker capacity

#12131 [Bug][Connector-V2][Doris][Zeta] DorisSchemaChangeIT: MODIFY COLUMN cancels the open stream load and the pipeline restart fails with "schema-change-after checkpoint is already completed"

#12147 [Bug][Zeta] checkpoint-coordinator thread survives job cancellation (CANCELED job leaves its coordinator executor alive)

#12102 [STIP-38][Feature][Connector-V2] Add a Mem0-compatible agent memory sink

#11007 [Umbrella][Improve] Migrate Connector/Transform Validation to Declarative OptionRule — Claim & Tracking

#12078 [Bug][Connector-V2][File] Content comparison can misclassify identical streams with different read boundaries

#12138 [Bug][Connector-V2][RocketMQ][Zeta] Duplicate messages after savepoint restore: enumerator rediscovers and reassigns queues the reader already restored

#10753 [Umbrella][Feature][Connector] Support New Connectors — Claim & Tracking

#12060 [Improve][Zeta] Investigate and improve finished JobDAG store benchmark stability

#12063 [Improve][Zeta] Investigate and improve job lifecycle growth benchmark stability

#12059 [Improve][Zeta] Investigate and improve intermediate queue benchmark stability

#12058 [Improve][Zeta] Investigate and optimize checkpoint state-store latency variance

#12086 [Umbrella][Performance] Track benchmark-driven optimizations and propose evidence guidelines

#12010 [Bug][Zeta] Interrupted pending-job insertion can be reported as successful

#12116 [Bug][Connector-V2][Assert] Multi-table row-count rules flaky on Flink: AssertSinkWriter uses static JVM-wide counters evaluated per-subtask close()

#12119 [Improve][Zeta] Define a two-phase admission contract so queued jobs do not retain a fully initialized JobMaster

#12118 [Improve][Zeta] Bound terminal-state notification delivery without dropping terminal events

#12132 [Bug][E2E][Flink] KuduIT hangs until the 90-minute job limit: the JobManager stops responding right after deploying the Kudu source task

#12123 [Improve][Zeta] Avoid full retained-history scans in the JobHistoryService listing path