aglinxinyuan opened a new issue, #5436: URL: https://github.com/apache/texera/issues/5436
Two small stateful manager classes in `amber/.../engine/architecture/worker/managers/`, neither covered today. | Surface | Behavior to pin | | --- | --- | | `StatisticsManager` | Default zero state across all counters / accumulators; `increaseInputStatistics` / `increaseOutputStatistics` accumulate per-port count and size; `require(size >= 0, ...)` rejects negative sizes; `getInputTupleCount` / `getOutputTupleCount` sum across ports; `getStatistics` projects to `WorkerStatistics` (with idle time = total − dataProcessing − controlProcessing); `increaseDataProcessingTime` / `increaseControlProcessingTime` reject negative time; `initializeWorkerStartTime` + `updateTotalExecutionTime` together compute elapsed time, and `updateTotalExecutionTime` rejects times before `workerStartTime`. | | `SerializationManager` | `setOpInitialization` records the `InitializeExecutorRequest`; `restoreExecutorState` requires `actorId` be a worker (not controller) and throws `IllegalStateException` otherwise; on `OpExecWithClassName` it instantiates via `ExecFactory.newExecFromJavaClassName`; on unsupported `OpExecInitInfo` it throws `UnsupportedOperationException`; non-`CheckpointSupport` executors return an empty restoration iterator. `registerSerialization` records a callback; `applySerialization` invokes it once and clears it (idempotent on second call). | ### 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]
