aglinxinyuan opened a new issue, #4828: URL: https://github.com/apache/texera/issues/4828
### Task Summary The five files in `amber/src/main/scala/org/apache/texera/amber/engine/common/ambermessage` (`WorkflowMessage`, `WorkflowFIFOMessagePayload`, `DirectControlMessagePayload`, `RecoveryPayload`) define the message envelopes that flow through the engine, but only `DataFrame.equals`/`DataFrame.inMemSize` is currently tested. Add `AmberMessageEnvelopesSpec`: - `WorkflowFIFOMessage` and `WorkflowRecoveryMessage` envelope shape - `RecoveryPayload` subtypes (`UpdateRecoveryStatus`, `ResendOutputTo`, `NotifyFailedNode`) carry their args; the `ResendOutputTo` ActorRef field is exercised via a real Pekko `ActorSystem` - `WorkflowMessage.getInMemSize` returns the `DataFrame.inMemSize` for a DataFrame payload, zero for an empty-frame, and defaults to 200L for any other WorkflowFIFOMessagePayload - `WorkflowFIFOMessagePayload` and `DirectControlMessagePayload` traits are implementable ### Priority P3 – Low ### Task Type - [x] Testing / QA -- 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]
