This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-angular-19
in repository https://gitbox.apache.org/repos/asf/texera.git
from ba1782d239 Merge branch 'main' into xinyuan-angular-19
add e635dd027d feat(amber): Re-enable operator reconfiguration in Amber
(#4220)
add 171bf33032 Merge branch 'main' into xinyuan-angular-19
No new revisions were added by this update.
Summary of changes:
.github/workflows/github-action-build.yml | 5 +
.../engine/architecture/rpc/controlcommands.proto | 22 +-
.../architecture/rpc/controllerservice.proto | 1 +
.../engine/architecture/rpc/workerservice.proto | 1 +
.../handlers/control/update_executor_handler.py | 27 +-
.../rpc/async_rpc_handler_initializer.py | 4 +
amber/src/main/python/core/runnables/main_loop.py | 8 +-
.../main/python/core/runnables/network_receiver.py | 5 +-
.../amber/engine/architecture/rpc/__init__.py | 99 +++++--
.../ControllerAsyncRPCHandlerInitializer.scala | 3 +-
.../promisehandlers/ReconfigurationHandler.scala | 124 ++++++++
.../DataProcessorRPCHandlerInitializer.scala | 28 +-
.../InitializeExecutorHandler.scala | 18 +-
...erHandler.scala => UpdateExecutorHandler.scala} | 18 +-
.../common}/FriesReconfigurationAlgorithm.scala | 55 ++--
.../amber/engine/e2e/ReconfigurationSpec.scala | 312 +++++++++++++++++++++
.../texera/amber/operator/TestOperators.scala | 20 ++
17 files changed, 649 insertions(+), 101 deletions(-)
create mode 100644
amber/src/main/scala/org/apache/texera/amber/engine/architecture/controller/promisehandlers/ReconfigurationHandler.scala
copy
amber/src/main/scala/org/apache/texera/amber/engine/architecture/worker/promisehandlers/{FlushNetworkBufferHandler.scala
=> UpdateExecutorHandler.scala} (71%)
rename amber/src/main/scala/org/apache/texera/{web/service =>
amber/engine/common}/FriesReconfigurationAlgorithm.scala (72%)
create mode 100644
amber/src/test/scala/org/apache/texera/amber/engine/e2e/ReconfigurationSpec.scala
