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/03/02 03:08:02 UTC
[beam] tag nightly-master updated (990de63 -> a834a75)
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 990de63 (commit)
to a834a75 (commit)
from 990de63 Merge pull request #14013 from [BEAM-11833] Fix reported watermark after restriction split in UnboundedSourceAsSDFRestrictionTracker
add b853f9c [BEAM-10961] enable strict dependency checking for sdks/java/extensions/zetasketch (#14093)
add 1438b05 Map Dataflow JOB_STATE_CANCELLING to Beam RUNNING state
add 3dba1d3 Merge pull request #14116: Map Dataflow JOB_STATE_CANCELLING to Beam RUNNING state
add 21a11fd Adding a warning to use multi-workers on FnApiRunner
add 0aa07a5 Merge pull request #14108 from pabloem/fnwarning
add 979a3bf [BEAM-10961] enable strict dependency checking for flink/job-server
add 3eea80d [BEAM-10761] add reference to BEAM-11761
add 7450e57 Merge pull request #14115 from sonam-vend/fix-flink-job-server
add d807210 [BEAM-11740] Estimate PCollection byte size
add 9150193 Merge pull request #13924 from [BEAM-11740] Estimate PCollection byte size
add a834a75 jdbc python supported Dataflow runner (#13960)
No new revisions were added by this update.
Summary of changes:
.../beam/runners/core/metrics/LabeledMetrics.java | 6 +
runners/flink/1.10/job-server/build.gradle | 4 -
runners/flink/1.11/job-server/build.gradle | 4 -
runners/flink/1.12/job-server/build.gradle | 4 -
runners/flink/1.8/job-server/build.gradle | 4 -
runners/flink/1.9/job-server/build.gradle | 4 -
runners/flink/job-server/flink_job_server.gradle | 2 +
.../beam/runners/dataflow/util/MonitoringUtil.java | 1 +
...ingCounter.java => DelegatingDistribution.java} | 38 +++---
sdks/java/extensions/zetasketch/build.gradle | 2 +
.../beam/fn/harness/BeamFnDataWriteRunner.java | 4 +-
.../org/apache/beam/fn/harness/CombineRunners.java | 4 +-
.../org/apache/beam/fn/harness/FlattenRunner.java | 29 ++++-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 5 +-
.../org/apache/beam/fn/harness/MapFnRunners.java | 29 ++++-
.../harness/data/PCollectionConsumerRegistry.java | 119 ++++++++++++++++---
.../beam/fn/harness/AssignWindowsRunnerTest.java | 15 ++-
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 5 +-
.../apache/beam/fn/harness/CombineRunnersTest.java | 108 ++++++++++++++---
.../apache/beam/fn/harness/FlattenRunnerTest.java | 47 ++++++--
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 129 +++++++++++++++++----
.../apache/beam/fn/harness/MapFnRunnersTest.java | 32 +++--
.../data/PCollectionConsumerRegistryTest.java | 55 ++++++---
sdks/python/apache_beam/io/jdbc.py | 2 +-
sdks/python/apache_beam/runners/common.py | 39 +++++++
.../runners/dataflow/dataflow_runner.py | 38 +-----
.../runners/dataflow/dataflow_runner_test.py | 9 +-
.../runners/portability/fn_api_runner/fn_runner.py | 14 ++-
28 files changed, 560 insertions(+), 192 deletions(-)
copy sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{DelegatingCounter.java => DelegatingDistribution.java} (65%)