carloea2 opened a new issue, #8199: URL: https://github.com/apache/texera/issues/8199
## What happened? OutputManager starts result and state storage writers before checking whether an output port has already been registered. Replaying the same port assignment therefore starts another writer pair and overwrites the tracked registry entries, while the original threads remain untracked by normal close logic. Before: one registered port produces two storage setup calls when the assignment is repeated. After: port schema and storage writers are initialized together only on the first registration. ## How to reproduce? 1. Create an OutputManager. 2. Add output port 0 with a storage URI. 3. Add the same logical port and URI again. 4. Observe that only one port exists. 5. Observe that set_up_port_storage_writer was called twice. ## Version/Branch 1.3.0-incubating-SNAPSHOT (main) ## Commit Hash 70c21145887920528d7d5540e3fb790b43e8b759 ## Relevant log output registered_ports=1 storage_setup_calls=2 -- 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]
