sshiv012 commented on PR #8668: URL: https://github.com/apache/texera/pull/8668#issuecomment-5838958132
@Ma77Ball Thanks, good call. Done in 1d583d5. The failure arrived as a plain `Throwable` (rebuilt from the worker's `ControlError`), so `relatedWorkerId` was always `None`. Now each per-worker RPC that launches a region (`initializeExecutor`, `assignPort`, `openExecutor`, `startWorker`) wraps a failure as `WorkflowRuntimeException(msg, cause, Some(workerId))`. The existing `FatalError(err, err.relatedWorkerId)` then carries the worker ID, and the UI can attribute the error to that operator. The tests now assert the worker ID too, and they failed before this change: - unit: `relatedWorkerId == Some(udfWorkerId)` - e2e: the Python UDF's worker ID `architecture.*` 770/770, and scalafix and scalafmt are clean. -- 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]
