davidzollo commented on issue #10546: URL: https://github.com/apache/seatunnel/issues/10546#issuecomment-3976735518
> I've reviewed the source code and can confirm this documentation task is well-defined and accurate. > > The file `seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java` contains all the classes and methods listed in your issue: > > * `CooperativeTaskWorker` (L731) - work-stealing execution for non-blocking tasks > * `BlockingWorker` (L656) - dedicated thread execution for blocking I/O tasks > * `RunBusWorkSupplier` (L838) - dynamic worker thread scaling > * `TaskGroupExecutionTracker` (L866) - task group lifecycle management > > The dual execution model logic is confirmed at L372-399, where tasks are partitioned by `ThreadShareMode` (ALL/OFF/PART) into cooperative or blocking queues. However, the 8 methods you listed (including `submitThreadShareTask`, `deployTask`, `notifyTaskStatusToMaster`, and inner class methods) currently lack Javadoc. > > This is a good `help wanted` issue for contributors to improve codebase understandability of Zeta engine's task scheduling mechanism. Yes, please leave a message if anybody who'd like to implement it -- 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]
