This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 8af69d7 Merge pull request #17081 from
brachi-wernick/BEAM-14094-fix-HllCountInitFn-npe
add ef8887e [BEAM-12815] Try to fix flaky Flink Post Commit (#17227)
add 282095b [BEAM-14179] Fix possibly null value
add 788299a Merge pull request #17228: [BEAM-14179] Fix possibly null
value
add c401788 Add a portable job server that proxies the Dataflow backend.
(#17189)
add 32cec70 [BEAM-14130] Implement JupyterLab extension for managing
Dataproc clusters (#17127)
add c50f562 [BEAM-14190] Python sends dataflow schema field
add 01d3cd7 Merge pull request #17190: [BEAM-14190] Python sends dataflow
schema field for pre-portability pipelines
add 5d186ea [BEAM-14164] [Website] change styles
add 4dddaf9 Merge pull request #17171 from
akvelon/BEAM-14164-fix-playground-on-homepage
add 141bb28 [BEAM-13951] Update release guide with pointers on updating
mass_comment.py (#17237)
add f38e0c4 [BEAM-13741] Remove forced calcite dependency from
BaseBeamTable
add ca47cd8 Merge pull request #17230: [BEAM-13741] Remove forced calcite
dependency from BaseBeamTable
No new revisions were added by this update.
Summary of changes:
...ommit_CrossLanguageValidatesRunner_Flink.groovy | 1 +
runners/flink/src/test/resources/flink-conf.yaml | 2 +
sdks/go/test/resources/flink-conf.yaml | 20 --
sdks/go/test/run_validatesrunner_tests.sh | 2 +-
sdks/java/extensions/sql/hcatalog/build.gradle | 11 -
.../sql/meta/provider/hcatalog/HCatalogTable.java | 7 -
.../sql/impl/schema/BeamPCollectionTable.java | 7 -
.../sdk/extensions/sql/meta/BaseBeamTable.java | 9 +-
.../sql/meta/provider/bigtable/BigtableTable.java | 7 -
.../sql/meta/provider/parquet/ParquetTable.java | 7 -
.../sql/impl/rel/BeamEnumerableConverterTest.java | 6 -
.../impl/rel/BeamSideInputLookupJoinRelTest.java | 7 -
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 3 +-
sdks/python/apache_beam/coders/row_coder.py | 9 +
sdks/python/apache_beam/coders/row_coder_test.py | 11 +
.../python/apache_beam/options/pipeline_options.py | 3 +-
.../runners/dataflow/dataflow_job_service.py | 91 +++++++
.../runners/dataflow/dataflow_job_service_test.py | 59 +++++
.../runners/dataflow/dataflow_runner.py | 97 ++++---
.../dataproc/dataproc_cluster_manager.py | 22 +-
.../dataproc/dataproc_cluster_manager_test.py | 2 +-
.../interactive/dataproc/types.py} | 27 +-
.../apache-beam-jupyterlab-sidepanel/package.json | 4 +-
.../src/SidePanel.ts | 28 +-
.../src/__tests__/clusters/Clusters.test.tsx | 105 ++++++++
.../src/clusters/Clusters.tsx | 288 +++++++++++++++++++++
.../ClustersWidget.tsx} | 19 +-
.../apache-beam-jupyterlab-sidepanel/src/index.ts | 89 ++++++-
.../apache-beam-jupyterlab-sidepanel/tsconfig.json | 1 +
.../runners/interactive/interactive_beam.py | 37 +++
.../runners/interactive/interactive_beam_test.py | 65 ++++-
.../interactive/interactive_environment_test.py | 2 +-
.../runners/interactive/interactive_runner.py | 15 +-
.../runners/interactive/interactive_runner_test.py | 2 +-
.../messaging/interactive_environment_inspector.py | 33 +++
.../interactive_environment_inspector_test.py | 26 ++
.../runners/portability/local_job_service.py | 16 +-
.../runners/portability/portable_runner.py | 18 +-
sdks/python/scripts/generate_pydoc.sh | 1 +
website/www/site/assets/scss/_playground.sass | 4 +-
.../site/content/en/contribute/release-guide.md | 8 +-
website/www/site/layouts/index.html | 2 +-
42 files changed, 954 insertions(+), 219 deletions(-)
delete mode 100644 sdks/go/test/resources/flink-conf.yaml
create mode 100644
sdks/python/apache_beam/runners/dataflow/dataflow_job_service.py
create mode 100644
sdks/python/apache_beam/runners/dataflow/dataflow_job_service_test.py
copy sdks/python/apache_beam/{coders/avro_record.py =>
runners/interactive/dataproc/types.py} (61%)
create mode 100644
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/__tests__/clusters/Clusters.test.tsx
create mode 100644
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/clusters/Clusters.tsx
copy
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/{inspector/InteractiveInspectorWidget.tsx
=> clusters/ClustersWidget.tsx} (55%)
