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/02/28 03:05:13 UTC
[beam] tag nightly-master updated (9035a92 -> d3295f8)

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 9035a92  (commit)
      to d3295f8  (commit)
    from 9035a92  Merge pull request #14095 from robertwb/merging-windows
     add 637b812  Fix compile breakage in WindmillStateInternals
     add 14e8d40  Fix checkstyle in watermark latency benchmark
     add 687035c  Merge pull request #14109: Fix Java precommit breakage
     add 3a438fa  Remove InvalidWindows from Java SDK, instead track "already merged" bit
     add 4764c0a  Merge pull request #14059: [BEAM-11866] Remove InvalidWindows from Java SDK, instead track "already merged" bit
     add 4957125  Exclude MapState example integration tests from Dataflow runner v2 suite
     add d3295f8  Merge pull request #14111: Exclude MapState example integration tests from Dataflow runner v2 suite

No new revisions were added by this update.

Summary of changes:
 .../construction/WindowingStrategyTranslation.java |  4 +-
 .../apache/beam/runners/core/ReduceFnRunner.java   |  4 +-
 .../beam/runners/direct/MultiStepCombine.java      |  2 +-
 .../flink/FlinkBatchTransformTranslators.java      |  4 +-
 .../flink/FlinkStreamingTransformTranslators.java  |  2 +-
 .../functions/FlinkPartialReduceFunction.java      |  2 +-
 .../translation/functions/FlinkReduceFunction.java |  2 +-
 .../functions/HashingFlinkCombineRunner.java       |  2 +-
 .../functions/SortingFlinkCombineRunner.java       |  2 +-
 runners/google-cloud-dataflow-java/build.gradle    |  1 +
 .../dataflow/DataflowPipelineTranslator.java       |  5 +-
 .../beam/runners/dataflow/DataflowRunner.java      |  2 +-
 .../transforms/DataflowGroupByKeyTest.java         | 24 ------
 .../dataflow/transforms/DataflowViewTest.java      | 71 -----------------
 .../dataflow/worker/WindmillStateInternals.java    |  8 +-
 .../util/BatchGroupAlsoByWindowViaIteratorsFn.java |  2 +-
 .../org/apache/beam/runners/spark/SparkRunner.java |  2 +-
 .../translation/batch/AggregatorCombiner.java      |  2 +-
 .../GroupNonMergingWindowsFunctions.java           |  2 +-
 .../runners/spark/translation/SparkCombineFn.java  |  2 +-
 .../org/apache/beam/sdk/transforms/Distinct.java   |  2 +-
 .../org/apache/beam/sdk/transforms/GroupByKey.java | 22 +-----
 .../sdk/transforms/windowing/InvalidWindows.java   | 90 ----------------------
 .../beam/sdk/transforms/windowing/Window.java      | 18 +----
 .../org/apache/beam/sdk/util/IdentityWindowFn.java | 11 +--
 .../apache/beam/sdk/values/PCollectionViews.java   |  4 -
 .../apache/beam/sdk/values/WindowingStrategy.java  | 65 +++++++++++++---
 .../apache/beam/sdk/transforms/GroupByKeyTest.java | 70 +++++++++--------
 .../org/apache/beam/sdk/transforms/ViewTest.java   | 42 ----------
 .../sdk/testing/watermarks/WatermarkLatency.java   |  3 +-
 .../beam/sdk/testing/watermarks}/package-info.java |  5 +-
 31 files changed, 129 insertions(+), 348 deletions(-)
 delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/InvalidWindows.java
 copy sdks/java/{extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf => testing/watermarks/src/main/java/org/apache/beam/sdk/testing/watermarks}/package-info.java (90%)