[Feature][Zeta] Report table-level lineage from the Zeta master
Nobody has claimed this yet.
- Dominant language
- Java
- Stars
- 9.7k
- Forks
- 2.4k
- Avg merge
- 3d 9h
- Merged PRs (30d)
- 204
Description
Part of the umbrella #12207, depends on #12204 (the shared seatunnel-lineage/seatunnel-lineage-openlineage modules). Adds the Zeta engine's call site.
What's needed
A ZetaLineageReporter, wired from the job master (JobMaster / PhysicalPlan / CheckpointCoordinator), that when openlineage_enabled = true:
- Sends a START event when a job's pipeline begins.
- Sends a throttled RUNNING heartbeat on completed checkpoints, so long-running streaming jobs don't go stale in a lineage graph — throttled by
openlineage_heartbeat_min_interval_ms(default 1 hour) since checkpoints can complete every few seconds and Zeta has no other natural place to hang a periodic callback. - Sends a terminal COMPLETE/FAIL/ABORT event when the pipeline ends, with output row-count/byte-size statistics read from the job's own
SinkCommittedCount/SinkWriteCountmetrics (falling back to the "attempted" counts if nothing has committed yet, flagged with anoutput_statistics_semanticsfacet so a consumer of the event knows which one it's looking at — Zeta and Flink end up reporting structurally different semantics here, and both need to say so rather than silently disagreeing). - Splits a multi-table sink's event into one event per underlying table, and derives each table's OpenLineage dataset name from its
CatalogTableper the shared naming logic in #12204.
Backward compatibility
Reporting is off unless a job explicitly sets openlineage_enabled = true. No change to checkpoint behavior, job scheduling, or existing metrics when disabled.
Contributor guide
No contributing guide indexed for this repository
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start with the shared seatunnel-lineage and seatunnel-lineage-openlineage modules from #12204, then trace the Zeta job flow through JobMaster, PhysicalPlan, and CheckpointCoordinator. Define the ZetaLineageReporter integration around those entry points, including enabled/disabled behavior, checkpoint heartbeat throttling, terminal events, per-table datasets, and the stated output-statistics semantics.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- data-engineering, distributed-systems
- Issue type
- Feature
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Active
- Clarity
- Mostly clear
- Newbie friendliness
- 42/100