Ma77Ball opened a new issue, #5713: URL: https://github.com/apache/texera/issues/5713
### Task Summary The synchronous execution endpoint (`SyncExecutionResource::executeWorkflowSync`) uses two unconditional `Thread.sleep(500)` calls to wait for the result writer to flush before reading results, adding ~1s of latency to every run. The engine already commits the result writer (via the worker's blocking `writerThread.join()`) before an operator's `COMPLETED` state becomes observable, so the data is on disk by the time we read it. Replace both sleeps with a bounded readiness-poll that compares each target operator's committed result-storage count against its expected output count from stats, with early-exit and a short timeout cap. ### Task Type - [x] Performance -- 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]
