You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2021/11/20 04:13:08 UTC
[beam] branch nightly-refs/heads/master updated (9fe2a27 -> 213bb784)
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 9fe2a27 [BEAM-13287] Fix improper thread usage in Pub/Sub Lite SDF that causes it to corrupt state in bundles across work items
add c2af5c4 [BEAM-13290] Handle disable_prime_runner_v2 flag (#16018)
add 6a13c4b [BEAM-11936] Add configuration parameter for suppressing unusedvariable check (#16010)
add b9a6125 Merge pull request #15957 from [BEAM-13045][Playground] Implemented examples api
add 4392c58 [BEAM-13286] RowJson should expect ReadableInstant for DATETIME values in Rows (#16015)
add 85e6c78 Merge pull request #16025 from [BEAM-13216] [Playground] Add client to send found tagged file to the backend
add dcc2a1a Add future back to Beam containers.
add c4d2329 Add future back to Beam container deps. #16023
add bcbec3f Updated dep and goldens for Interactive Beam screen diff tests
add 4235195 Updated dep and goldens for Interactive Beam screen diff tests
add 2c1a29b Merge pull request #16013 from [BEAM-13281] [playground] Update favicon and metadata
add b6bc642 Merge pull request #15768 from [BEAM-13064] [Playground] Implement search & filter logic
add 09d8fb7 Added go code coverage report with codecov (#16020)
add 5e60e3b Removed Pillow from requirements of containers.
add 213bb784 Removed Pillow from requirements of containers. #16029
No new revisions were added by this update.
Summary of changes:
.github/codecov.yml | 6 +
.github/workflows/{cancel.yml => go_tests.yml} | 42 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 11 +-
examples/java/build.gradle | 1 +
examples/java/twitter/build.gradle | 1 +
examples/kotlin/build.gradle | 2 +-
playground/api/v1/api.proto | 52 +-
playground/backend/cmd/server/controller.go | 383 ++++++-
playground/backend/go.mod | 2 +
playground/backend/go.sum | 90 +-
playground/backend/internal/api/v1/api.pb.go | 502 +++++-----
playground/backend/internal/api/v1/api_grpc.pb.go | 94 +-
.../internal/cloud_bucket/precompiled_objects.go | 278 +++++
.../cloud_bucket/precompiled_objects_test.go | 222 ++++
playground/frontend/lib/api/v1/api.pb.dart | 190 ++--
playground/frontend/lib/api/v1/api.pbenum.dart | 24 +-
playground/frontend/lib/api/v1/api.pbgrpc.dart | 129 +--
playground/frontend/lib/api/v1/api.pbjson.dart | 79 +-
.../components/example_list/example_list.dart | 34 +-
.../components/filter/category_bubble.dart | 71 +-
.../examples/components/filter/type_filter.dart | 9 +-
.../components/search_field/search_field.dart | 82 +-
.../lib/modules/examples/example_selector.dart | 153 ++-
.../modules/examples/models/category_model.dart | 2 +-
.../lib/modules/examples/models/example_model.dart | 16 +
.../examples/repositories/example_repository.dart | 20 +-
.../lib/pages/playground/playground_page.dart | 6 +-
.../playground/states/example_dropdown_state.dart | 32 -
.../playground/states/example_selector_state.dart | 105 ++
.../pages/playground/states/examples_state.dart | 8 +-
.../states/example_selector_state_test.dart | 102 ++
.../playground/states/mocks/categories_mock.dart | 160 +++
.../images => playground/frontend/web}/favicon.ico | Bin
playground/frontend/web/favicon.png | Bin 917 -> 0 bytes
playground/frontend/web/icons/Icon-192.png | Bin 5292 -> 0 bytes
playground/frontend/web/icons/Icon-512.png | Bin 8252 -> 0 bytes
.../frontend/web/icons/Icon-maskable-192.png | Bin 5594 -> 0 bytes
.../frontend/web/icons/Icon-maskable-512.png | Bin 20998 -> 0 bytes
playground/frontend/web/index.html | 8 +-
playground/infrastructure/api/api_pb2.py | 1059 ++++++++++++++++++++
playground/infrastructure/api/api_pb2_grpc.py | 319 ++++++
.../infrastructure/config.py | 11 +-
playground/infrastructure/grpc_client.py | 122 +++
playground/infrastructure/test_grpc_client.py | 81 ++
runners/core-construction-java/build.gradle | 1 +
runners/core-java/build.gradle | 1 +
runners/direct-java/build.gradle | 1 +
runners/extensions-java/metrics/build.gradle | 1 +
runners/flink/flink_runner.gradle | 1 +
runners/google-cloud-dataflow-java/build.gradle | 1 +
.../examples-streaming/build.gradle | 2 +-
.../examples/build.gradle | 2 +-
.../beam/runners/dataflow/DataflowRunner.java | 3 +-
.../google-cloud-dataflow-java/worker/build.gradle | 1 +
.../worker/legacy-worker/build.gradle | 1 +
runners/java-fn-execution/build.gradle | 1 +
runners/java-job-service/build.gradle | 1 +
runners/jet/build.gradle | 1 +
runners/local-java/build.gradle | 1 +
runners/portability/java/build.gradle | 2 +-
runners/samza/build.gradle | 1 +
runners/samza/job-server/build.gradle | 1 +
runners/spark/spark_runner.gradle | 1 +
runners/twister2/build.gradle | 1 +
sdks/java/build-tools/build.gradle | 2 +-
sdks/java/core/build.gradle | 1 +
.../java/org/apache/beam/sdk/util/RowJson.java | 5 +-
.../java/org/apache/beam/sdk/util/RowJsonTest.java | 12 +-
sdks/java/expansion-service/build.gradle | 2 +
sdks/java/extensions/arrow/build.gradle | 2 +-
sdks/java/extensions/euphoria/build.gradle | 1 +
.../google-cloud-platform-core/build.gradle | 1 +
sdks/java/extensions/jackson/build.gradle | 1 +
sdks/java/extensions/join-library/build.gradle | 1 +
sdks/java/extensions/kryo/build.gradle | 2 +-
sdks/java/extensions/ml/build.gradle | 1 +
sdks/java/extensions/protobuf/build.gradle | 1 +
.../schemaio-expansion-service/build.gradle | 1 +
sdks/java/extensions/sketching/build.gradle | 1 +
sdks/java/extensions/sorter/build.gradle | 1 +
sdks/java/extensions/sql/build.gradle | 1 +
sdks/java/extensions/sql/datacatalog/build.gradle | 1 +
.../extensions/sql/expansion-service/build.gradle | 1 +
sdks/java/extensions/sql/hcatalog/build.gradle | 1 +
sdks/java/extensions/sql/jdbc/build.gradle | 2 +-
sdks/java/extensions/sql/perf-tests/build.gradle | 1 +
.../extensions/sql/udf-test-provider/build.gradle | 1 +
sdks/java/extensions/sql/udf/build.gradle | 1 +
sdks/java/extensions/sql/zetasql/build.gradle | 1 +
sdks/java/extensions/zetasketch/build.gradle | 1 +
sdks/java/fn-execution/build.gradle | 1 +
sdks/java/harness/build.gradle | 1 +
sdks/java/io/amazon-web-services/build.gradle | 1 +
sdks/java/io/amazon-web-services2/build.gradle | 1 +
sdks/java/io/amqp/build.gradle | 2 +-
sdks/java/io/azure/build.gradle | 1 +
sdks/java/io/bigquery-io-perf-tests/build.gradle | 2 +-
sdks/java/io/cassandra/build.gradle | 1 +
sdks/java/io/clickhouse/build.gradle | 1 +
sdks/java/io/common/build.gradle | 2 +-
sdks/java/io/contextualtextio/build.gradle | 1 +
sdks/java/io/debezium/build.gradle | 1 +
.../io/debezium/expansion-service/build.gradle | 1 +
.../elasticsearch-tests-5/build.gradle | 1 +
.../elasticsearch-tests-6/build.gradle | 1 +
.../elasticsearch-tests-7/build.gradle | 1 +
.../elasticsearch-tests-common/build.gradle | 1 +
sdks/java/io/elasticsearch/build.gradle | 2 +-
sdks/java/io/expansion-service/build.gradle | 1 +
sdks/java/io/file-based-io-tests/build.gradle | 2 +-
sdks/java/io/google-cloud-platform/build.gradle | 1 +
.../expansion-service/build.gradle | 1 +
sdks/java/io/hadoop-common/build.gradle | 2 +-
sdks/java/io/hadoop-file-system/build.gradle | 1 +
sdks/java/io/hadoop-format/build.gradle | 1 +
sdks/java/io/hbase/build.gradle | 2 +-
sdks/java/io/hcatalog/build.gradle | 2 +-
sdks/java/io/influxdb/build.gradle | 2 +-
sdks/java/io/jdbc/build.gradle | 1 +
sdks/java/io/jms/build.gradle | 1 +
sdks/java/io/kafka/build.gradle | 1 +
sdks/java/io/kinesis/build.gradle | 2 +-
.../java/io/kinesis/expansion-service/build.gradle | 1 +
sdks/java/io/kudu/build.gradle | 1 +
sdks/java/io/mongodb/build.gradle | 2 +-
sdks/java/io/mqtt/build.gradle | 2 +-
sdks/java/io/parquet/build.gradle | 1 +
sdks/java/io/rabbitmq/build.gradle | 2 +-
sdks/java/io/redis/build.gradle | 2 +-
sdks/java/io/snowflake/build.gradle | 1 +
.../io/snowflake/expansion-service/build.gradle | 1 +
sdks/java/io/solr/build.gradle | 1 +
sdks/java/io/splunk/build.gradle | 2 +-
sdks/java/io/synthetic/build.gradle | 1 +
sdks/java/io/thrift/build.gradle | 1 +
sdks/java/io/tika/build.gradle | 2 +-
sdks/java/io/xml/build.gradle | 2 +-
sdks/java/javadoc/build.gradle | 2 +-
sdks/java/maven-archetypes/examples/build.gradle | 2 +-
.../maven-archetypes/gcp-bom-examples/build.gradle | 2 +-
sdks/java/maven-archetypes/starter/build.gradle | 2 +-
sdks/java/testing/expansion-service/build.gradle | 1 +
sdks/java/testing/jpms-tests/build.gradle | 1 +
sdks/java/testing/kafka-service/build.gradle | 2 +-
sdks/java/testing/load-tests/build.gradle | 1 +
sdks/java/testing/nexmark/build.gradle | 1 +
sdks/java/testing/test-utils/build.gradle | 1 +
sdks/java/testing/tpcds/build.gradle | 1 +
sdks/java/testing/watermarks/build.gradle | 1 +
.../Darwin/29c9237ddf4f3d5988a503069b4d3c47.png | Bin 67304 -> 67308 bytes
.../Darwin/7a35f487b2a5f3a9b9852a8659eeb4bd.png | Bin 750380 -> 762483 bytes
.../Linux/7a35f487b2a5f3a9b9852a8659eeb4bd.png | Bin 728268 -> 728108 bytes
.../container/base_image_requirements_manual.txt | 5 +-
.../container/py36/base_image_requirements.txt | 10 +-
.../container/py37/base_image_requirements.txt | 10 +-
.../container/py38/base_image_requirements.txt | 10 +-
sdks/python/setup.py | 2 +-
sdks/python/test-suites/direct/xlang/build.gradle | 2 +-
158 files changed, 3908 insertions(+), 791 deletions(-)
copy .github/workflows/{cancel.yml => go_tests.yml} (55%)
create mode 100644 playground/backend/internal/cloud_bucket/precompiled_objects.go
create mode 100644 playground/backend/internal/cloud_bucket/precompiled_objects_test.go
delete mode 100644 playground/frontend/lib/pages/playground/states/example_dropdown_state.dart
create mode 100644 playground/frontend/lib/pages/playground/states/example_selector_state.dart
create mode 100644 playground/frontend/test/pages/playground/states/example_selector_state_test.dart
create mode 100644 playground/frontend/test/pages/playground/states/mocks/categories_mock.dart
copy {website/www/site/static/images => playground/frontend/web}/favicon.ico (100%)
delete mode 100644 playground/frontend/web/favicon.png
delete mode 100644 playground/frontend/web/icons/Icon-192.png
delete mode 100644 playground/frontend/web/icons/Icon-512.png
delete mode 100644 playground/frontend/web/icons/Icon-maskable-192.png
delete mode 100644 playground/frontend/web/icons/Icon-maskable-512.png
create mode 100644 playground/infrastructure/api/api_pb2.py
create mode 100644 playground/infrastructure/api/api_pb2_grpc.py
copy sdks/python/apache_beam/portability/api/__init__.py => playground/infrastructure/config.py (84%)
create mode 100644 playground/infrastructure/grpc_client.py
create mode 100644 playground/infrastructure/test_grpc_client.py