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 2020/07/02 02:42:53 UTC
[beam] tag nightly-master updated (23d0c47 -> 0fb562e)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 23d0c47 (commit)
to 0fb562e (commit)
from 23d0c47 Remove misleading unsupported features mention for Python streaming (#12140)
add 09258f2 [BEAM-10321] retain environments in flatten for preventing it from being fused into stages running in foreign language SDKs
add 1805c66 Merge pull request #12087 from [BEAM-10321] retain environments in flatten for preventing it from be…
add c982a1c Bug fix: non 200 response streams are read twice which cause "Cannot read from closed stream" errors.
add e183ea6 Merge pull request #12103 from lastomato/fix_api_client: Bug fix: non 200 response streams are read twice which cause "Cannot …
add ac0f4f0 MetricFilter matching by Metric objects.
add 407b014 Merge pull request #12123 from rainwoodman/query-by-metric: MetricFilter matching by Metric objects.
add 1817402 Update ZetaSQL to 2020.06.1 release.
add 4863968 Merge pull request #12138 from ibzib/zetasql-release
add f1eebfa [BEAM-10291] Adding full thread dump upon lull detection (#12047)
add 592ab72 [BEAM-10322] allow only single assignment to producing stages by pcollection map
add 709c2c5 Merge pull request #12086 from [BEAM-10322] allow only single assignment to producing stages by pcol…
add 78be15f Add nexmark option to allow cancel streaming query job after complete
add ea928a2 Merge pull request #12119 from y1chi/nexmark
add 46276b5 Change GroupIntoBatches to group for real
add 8f86cec Merge pull request #12129 from aaltay/gib
add a4f3019 [BEAM-10391] Add attribute map null check in dataflow worker (#12136)
add 68a3a73 [BEAM-10327] Create a pattern that shows use of Schema using Joins (#12097)
add a5c32f3 [BEAM-9953] [ZetaSQL] Implement CREATE FUNCTION and scalar UDF. (#12153)
add e5ee374 [BEAM-9754] Add Py 3.8 support to Dataflow runner.
add 190b69d Print a warning when users install version of Beam that has not been sufficiently tested.
add d6fcc1e Merge pull request #12156 from tvalentyn/py38_support
add 02b184e Moving to 2.24.0-SNAPSHOT on master branch.
add ea4aa6b [BEAM-10318] fix uninitialized grpc_server in FnApiRunner
add 05fea6b Merge pull request #12085 from [BEAM-10318] fix uninitialized grpc_server in FnApiRunner
add ea6aa88 Add Branching to Go SDK katas (#12113)
add 0fb562e Fix typo (#12160)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 6 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../apache/beam/examples/snippets/Snippets.java | 70 ++++++++++++
.../beam/examples/snippets/SnippetsTest.java | 71 ++++++++++++
gradle.properties | 4 +-
.../Flatten => Branching/Branching}/cmd/main.go | 12 +-
.../Branching}/go.mod | 4 +-
.../Branching}/go.sum | 21 +---
.../Branching}/pkg/task/task.go | 29 +++--
.../Branching}/task-info.yaml | 24 ++--
.../Branching/Branching/task-remote-info.yaml | 2 +
.../Core Transforms/Branching/Branching/task.md | 16 ++-
.../Branching}/test/task_test.go | 18 +--
.../Core Transforms/Branching/lesson-info.yaml | 0
.../Branching/lesson-remote-info.yaml | 3 +
.../katas/go/Core Transforms/section-info.yaml | 1 +
learning/katas/go/course-remote-info.yaml | 2 +-
.../beam/runners/dataflow/worker/PubsubSink.java | 12 +-
.../sql/meta/provider/FullNameTableProvider.java | 2 +-
sdks/java/extensions/sql/zetasql/build.gradle | 2 +-
.../sdk/extensions/sql/zetasql/SqlAnalyzer.java | 68 ++++++++++-
.../extensions/sql/zetasql/ZetaSQLPlannerImpl.java | 59 +++++++---
.../translation/AggregateScanConverter.java | 7 +-
.../translation/ArrayScanColumnRefToUncollect.java | 4 +-
.../zetasql/translation/ExpressionConverter.java | 94 ++++++++++++----
.../zetasql/translation/FilterScanConverter.java | 4 +-
.../sql/zetasql/translation/JoinScanConverter.java | 5 +-
.../LimitOffsetScanToLimitConverter.java | 6 +-
.../LimitOffsetScanToOrderByLimitConverter.java | 6 +-
.../sql/zetasql/ZetaSQLDialectSpecTest.java | 125 +++++++++++++++++++++
.../io/gcp/healthcare/HttpHealthcareApiClient.java | 22 ++--
.../beam/sdk/io/gcp/pubsub/PubsubMessage.java | 10 +-
.../apache/beam/sdk/nexmark/NexmarkLauncher.java | 3 +
.../apache/beam/sdk/nexmark/NexmarkOptions.java | 6 +
sdks/python/apache_beam/__init__.py | 9 +-
.../aggregation/groupintobatches_test.py | 12 +-
sdks/python/apache_beam/metrics/metric.py | 5 +
sdks/python/apache_beam/metrics/metric_test.py | 21 +++-
.../runners/dataflow/dataflow_runner_test.py | 63 -----------
.../runners/dataflow/internal/apiclient.py | 6 +-
.../runners/dataflow/internal/apiclient_test.py | 66 -----------
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
.../runners/dataflow/template_runner_test.py | 3 -
.../runners/portability/fn_api_runner/execution.py | 2 +
.../portability/fn_api_runner/translations.py | 6 +-
.../portability/fn_api_runner/worker_handlers.py | 2 +
.../apache_beam/runners/worker/sdk_worker.py | 26 ++++-
.../apache_beam/runners/worker/sdk_worker_test.py | 49 ++++++++
sdks/python/apache_beam/transforms/util.py | 9 +-
sdks/python/apache_beam/version.py | 2 +-
sdks/python/setup.py | 10 +-
.../content/en/documentation/patterns/overview.md | 3 +
.../content/en/documentation/patterns/schema.md | 57 ++++++++++
.../partials/section-menu/en/documentation.html | 1 +
54 files changed, 786 insertions(+), 290 deletions(-)
copy learning/katas/go/Core Transforms/{Flatten/Flatten => Branching/Branching}/cmd/main.go (83%)
copy learning/katas/go/Core Transforms/{Additional Outputs/Additional Outputs => Branching/Branching}/go.mod (87%)
copy learning/katas/go/Core Transforms/{Additional Outputs/Additional Outputs => Branching/Branching}/go.sum (95%)
copy learning/katas/go/Core Transforms/{Additional Outputs/Additional Outputs => Branching/Branching}/pkg/task/task.go (64%)
copy learning/katas/go/Core Transforms/{Combine/CombineFn => Branching/Branching}/task-info.yaml (87%)
create mode 100644 learning/katas/go/Core Transforms/Branching/Branching/task-remote-info.yaml
copy learning/katas/{java => go}/Core Transforms/Branching/Branching/task.md (64%)
copy learning/katas/go/Core Transforms/{Map/ParDo => Branching/Branching}/test/task_test.go (67%)
copy learning/katas/{python => go}/Core Transforms/Branching/lesson-info.yaml (100%)
create mode 100644 learning/katas/go/Core Transforms/Branching/lesson-remote-info.yaml
create mode 100644 website/www/site/content/en/documentation/patterns/schema.md