rameshreddy-adutla opened a new pull request, #10559: URL: https://github.com/apache/seatunnel/pull/10559
## Summary Closes #10540 Adds comprehensive Javadoc to all key methods in `SeaTunnelTask`, the abstract base class for all Zeta engine task executions. ## Changes **Class-level documentation:** - Describes the full task state machine (`CREATED → INIT → WAITING_RESTORE → READY_START → STARTING → RUNNING → PREPARE_CLOSE → CLOSED`) - Explains checkpoint coordination model **Method-level Javadoc added to:** | Method | What's documented | |--------|------------------| | `init()` | Flow-to-lifecycle conversion, metrics wiring, `flowFutures` registration | | `stateProcess()` | Full state machine transitions with all cases | | `convertFlowToActionLifeCycle(Flow)` | Recursive DAG traversal and output wiring | | `ack(Barrier)` | Per-cycle ACK accumulation, prepareClose detection, checkpoint ACK to coordinator | | `addState(Barrier, ActionStateKey, List<byte[]>)` | Per-action checkpoint state buffering | | `close()` | Ordered teardown with error aggregation | | `triggerSchemaChangeBeforeCheckpoint()` | DDL-before-checkpoint barrier propagation | | `triggerSchemaChangeAfterCheckpoint()` | DDL-after-checkpoint barrier propagation | ## Testing Documentation-only change — no functional changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
