davidzollo opened a new issue, #10543: URL: https://github.com/apache/seatunnel/issues/10543
Sub-issue of #10533 ## Scope `SinkFlowLifeCycle` is the runtime bridge between the Zeta engine and a connector's `SinkWriter`. It receives records and barriers from the upstream flow and manages `prepareCommit` / checkpoint state collection. ## File `seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java` ## Methods to document | Method | What to explain | |--------|-----------------| | `init()` | Writer creation path: fresh writer via `createWriter` vs restored writer via `restoreWriter` when checkpoint states are present | | `received(Record<?>)` | Barrier vs data row dispatch; on data: calls `writer.write()`; on barrier: triggers `triggerBarrier` flow | | `triggerBarrier(Barrier)` | Calls `writer.prepareCommit()`; collects commit info and states; propagates barrier downstream; close-barrier handling | | `close()` | Ordered teardown: `writer.close()` then `committer.close()` if present; error logging | ## How to contribute 1. Fork the repo and create a branch 2. Add Javadoc to the methods above 3. Run `./mvnw spotless:apply` and `./mvnw -q -DskipTests verify` 4. Open a PR with title: `[Docs][Core] Add Javadoc to SinkFlowLifeCycle` -- 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]
