This is an automated email from the ASF dual-hosted git repository. aglinxinyuan pushed a commit to branch xinyuan-state-materialization in repository https://gitbox.apache.org/repos/asf/texera.git
commit ffac23a8cdded5b1379ed31ab5c2f42fefa236ab Merge: 1fc823f197 3c21b7231d Author: Xinyuan Lin <[email protected]> AuthorDate: Tue May 5 19:12:03 2026 -0700 Merge branch 'main' into xinyuan-state-materialization Co-Authored-By: Claude Opus 4.7 (1M context) <[email protected]> .github/labeler.yml | 8 +-- .github/workflows/build.yml | 20 ++++--- .github/workflows/required-checks.yml | 4 +- .gitignore | 3 ++ access-control-service/LICENSE-binary | 2 +- amber/LICENSE-binary-java | 2 +- amber/LICENSE-binary-python | 2 +- amber/build.sbt | 10 ++-- amber/operator-requirements.txt | 2 +- amber/{src/main/python => }/pyproject.toml | 17 +++++- .../e2e/ReconfigurationIntegrationSpec.scala | 62 ++++++++++++++++++++++ .../handlers/control/test_debug_command_handler.py | 0 .../control/test_evaluate_expression_handler.py | 0 .../control/test_replay_current_tuple_handler.py | 0 .../control/test_update_executor_handler.py | 0 .../managers/test_console_message_manager.py | 0 .../architecture/managers/test_debug_manager.py | 0 .../test_embedded_control_message_manager.py | 0 .../managers/test_exception_manager.py | 0 .../architecture/managers/test_executor_manager.py | 0 .../architecture/managers/test_pause_manager.py | 0 .../architecture/managers/test_state_manager.py | 0 .../managers/test_state_processing_manager.py | 0 .../managers/test_statistics_manager.py | 0 .../managers/test_tuple_processing_manager.py | 0 .../architecture/packaging/test_output_manager.py | 0 .../core/architecture/rpc/test_async_rpc_client.py | 0 .../sendsemantics/test_partitioners.py | 0 .../python/core/models/schema/test_schema.py | 0 .../python/core/models/test_operator.py | 0 .../python/core/models/test_state.py | 0 .../python/core/models/test_table.py | 0 .../python/core/models/test_tuple.py | 0 .../python/core/models/type/test_large_binary.py | 0 .../python/core/proxy/test_proxy_client.py | 4 +- .../python/core/proxy/test_proxy_server.py | 2 +- .../python/core/runnables/test_console_message.py | 0 .../python/core/runnables/test_data_processor.py | 0 .../python/core/runnables/test_heartbeat.py | 0 .../python/core/runnables/test_main_loop.py | 0 .../python/core/runnables/test_network_receiver.py | 0 .../python/core/runnables/test_network_sender.py | 0 .../core/storage/iceberg/test_iceberg_document.py | 9 +++- .../storage/iceberg/test_iceberg_utils_catalog.py | 0 .../iceberg/test_iceberg_utils_large_binary.py | 0 ...t_input_port_materialization_reader_runnable.py | 0 .../python/core/storage/test_document_factory.py | 0 .../util/console_message/test_replace_print.py | 0 .../core/util/customized_queue/test_inner.py | 0 .../test_linked_blocking_multi_queue.py | 0 .../test_expression_evaluator.py | 2 +- .../python/core/util/thread/test_atomic.py | 0 .../util/virtual_identity/test_virtual_identity.py | 0 .../pytexera/storage/test_dataset_file_document.py | 0 .../storage/test_large_binary_input_stream.py | 0 .../pytexera/storage/test_large_binary_manager.py | 0 .../storage/test_large_binary_output_stream.py | 0 .../udf/examples/test_count_batch_operator.py | 2 +- .../pytexera/udf/examples/test_echo_operator.py | 2 +- .../udf/examples/test_echo_table_operator.py | 2 +- .../udf/examples/test_generator_operator_binary.py | 2 +- .../examples/test_generator_operator_integer.py | 2 +- bin/fix-format.sh | 11 ++-- common/dao/build.sbt | 2 +- common/workflow-core/build.sbt | 2 +- computing-unit-managing-service/LICENSE-binary | 2 +- config-service/LICENSE-binary | 2 +- file-service/LICENSE-binary | 2 +- frontend/angular.json | 4 -- .../component/dashboard.component.spec.ts | 20 ++++--- .../user-project-list-item.component.spec.ts | 39 ++++++++++---- .../user-workflow-list-item.component.spec.ts | 39 +++++++++++--- .../user-workflow/user-workflow.component.html | 1 - .../user-workflow/user-workflow.component.spec.ts | 20 ++++--- frontend/src/tsconfig.spec.json | 13 +---- workflow-compiling-service/LICENSE-binary | 2 +- 76 files changed, 224 insertions(+), 94 deletions(-) diff --cc amber/src/test/python/core/architecture/packaging/test_output_manager.py index 8f1daf8052,0000000000..8f1daf8052 mode 100644,000000..100644 --- a/amber/src/test/python/core/architecture/packaging/test_output_manager.py +++ b/amber/src/test/python/core/architecture/packaging/test_output_manager.py diff --cc amber/src/test/python/core/storage/iceberg/test_iceberg_document.py index 032376ae31,a218c64a2d..44e62bbb8a --- a/amber/src/test/python/core/storage/iceberg/test_iceberg_document.py +++ b/amber/src/test/python/core/storage/iceberg/test_iceberg_document.py @@@ -45,8 -49,7 +50,8 @@@ StorageConfig.initialize rest_catalog_uri="http://localhost:8181/catalog/";, rest_catalog_warehouse_name="texera", table_result_namespace="operator-port-result", + table_state_namespace="operator-port-state", - directory_path="../../../../../../amber/user-resources/workflow-results", + directory_path=tempfile.mkdtemp(prefix="texera-iceberg-warehouse-"), commit_batch_size=4096, s3_endpoint="http://localhost:9000";, s3_region="us-east-1", diff --cc amber/src/test/python/core/storage/runnables/test_input_port_materialization_reader_runnable.py index 838ba7b910,0000000000..838ba7b910 mode 100644,000000..100644 --- a/amber/src/test/python/core/storage/runnables/test_input_port_materialization_reader_runnable.py +++ b/amber/src/test/python/core/storage/runnables/test_input_port_materialization_reader_runnable.py diff --cc amber/src/test/python/core/storage/test_document_factory.py index 859c004024,0000000000..859c004024 mode 100644,000000..100644 --- a/amber/src/test/python/core/storage/test_document_factory.py +++ b/amber/src/test/python/core/storage/test_document_factory.py
