aglinxinyuan opened a new issue, #4414: URL: https://github.com/apache/texera/issues/4414
### Task Summary The State class currently carries a passToAllDownstream flag (Scala: State.passToAllDownstream / isPassToAllDownstream; Python: State.passToAllDownstream / pass_to_all_downstream). When I originally introduced this flag, I didn't think through the design carefully. Looking back: - The flag is never actually used anywhere in the codebase — no operator sets it to true, and the only reader is the default processState implementation itself. - There is no planned use case for it going forward. - The concept it was meant to gesture at (restricting how far state propagates) will be reintroduced later as a proper "scope" concept with a different mechanism, not via a boolean carried on every State instance. Proposed change: remove the flag from both State and OperatorExecutor / Operator in Scala and Python. After removal, the default behavior of processState becomes: pass the incoming state to all downstream operators, unless an operator explicitly consumes it by overriding processState and returning None. ### Priority P2 – Medium ### Task Type - [ ] Code Implementation - [ ] Documentation - [ ] Refactor / Cleanup - [ ] Testing / QA - [ ] DevOps / Deployment -- 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]
