beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (990de63 -> a834a75)
Date Tue, 02 Mar 2021 03:08:02 GMT
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%)


Mime
View raw message