[beam] tag nightly-master updated (a1e644a -> 31c0642)

[gi...@apache.org]

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 a1e644a  (commit)
      to 31c0642  (commit)
    from a1e644a  Merge pull request #12590 from lostluck/fixvendored
     add a76edaa  Scale progress with respect to windows observation.
     add 314caa8  Merge pull request #12430 from boyuanzz/scale_progress
     add f45b39a  [BEAM-8025] Update tests to use TemporaryFolder instead of rolling their own implementation.
     add ee08991  Merge pull request #12592 from [BEAM-8025] Update tests to use TemporaryFolder instead of rolling their own implementation.
     add 5893ee4  [BEAM-10612] Add flink 1.11 runner
     add efad73c  Merge pull request #12564: [BEAM-10612] Add Flink 1.11 Runner
     add 2e7c4ca  [BEAM-10670] Make Read execute as a splittable DoFn by default for the Java DirectRunner.
     add c720f2a  Merge pull request #12519 from lukecwik/beam10670
     add 2ec383d  Remove redundant setMaxNumRecords and consumerFactoryFn.
     add 31c0642  Merge pull request #12574 from boyuanzz/fix

No new revisions were added by this update.

Summary of changes:
 CHANGES.md                                         |  28 ++
 .../runners/core/construction/SplittableParDo.java |  47 ++
 .../core/construction/SplittableParDoTest.java     |  81 ++++
 .../apache/beam/runners/direct/DirectRunner.java   |   1 +
 .../direct/ImmutabilityEnforcementFactory.java     |  58 +++
 .../direct/BoundedReadEvaluatorFactoryTest.java    |  10 +-
 .../runners/direct/DirectGraphVisitorTest.java     |  27 +-
 .../beam/runners/direct/DirectRunnerTest.java      |   1 -
 .../beam/runners/direct/EvaluationContextTest.java |  37 +-
 .../direct/UnboundedReadEvaluatorFactoryTest.java  |  34 +-
 .../beam/runners/direct/WatermarkManagerTest.java  | 505 +++++++++++----------
 .../apache/beam/runners/flink/FlinkRunnerTest.java |  96 ----
 .../beam/runners/flink/FlinkRunnerTestCompat.java  |  42 ++
 runners/flink/{1.10 => 1.11}/build.gradle          |   8 +-
 .../job-server-container/build.gradle              |   0
 .../flink/{1.10 => 1.11}/job-server/build.gradle   |   2 +-
 .../streaming/AbstractStreamOperatorCompat.java}   |  14 +-
 .../beam/runners/flink/FlinkRunnerTestCompat.java  |  47 ++
 .../beam/runners/flink/RemoteMiniClusterImpl.java  |  31 +-
 .../runners/flink/SourceTransformationCompat.java} |  11 +-
 .../streaming/AbstractStreamOperatorCompat.java}   |  14 +-
 .../beam/runners/flink/FlinkRunnerTestCompat.java  |  43 ++
 .../runners/flink/SourceTransformationCompat.java} |  12 +-
 runners/flink/flink_runner.gradle                  |   4 +
 .../wrappers/streaming/DoFnOperator.java           |   9 +-
 .../streaming/io/UnboundedSourceWrapper.java       |   2 +-
 .../apache/beam/runners/flink/FlinkRunnerTest.java |  10 +-
 .../FlinkStreamingTransformTranslatorsTest.java    |  21 +-
 .../wrappers/streaming/DoFnOperatorTest.java       |   8 +-
 .../streaming/ExecutableStageDoFnOperatorTest.java |   8 +-
 .../runtime/SamzaTimerInternalsFactoryTest.java    |  21 +-
 .../src/main/resources/beam/suppressions.xml       |   1 +
 .../src/main/java/org/apache/beam/sdk/io/Read.java |  37 +-
 .../java/org/apache/beam/sdk/io/AvroIOTest.java    |  27 --
 .../org/apache/beam/sdk/io/TFRecordIOTest.java     |   4 -
 .../org/apache/beam/sdk/io/TextIOReadTest.java     |  26 --
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  55 ++-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |   6 +-
 .../beam/sdk/io/cassandra/CassandraIOTest.java     |  22 +-
 .../sdk/io/gcp/bigquery/BigQueryIOReadTest.java    |  41 --
 .../gcp/bigquery/BigQueryIOStorageQueryTest.java   |  11 -
 .../io/gcp/bigquery/BigQueryIOStorageReadTest.java |  15 -
 .../beam/sdk/io/gcp/bigtable/BigtableIOTest.java   |  30 --
 .../sdk/io/gcp/pubsub/PubsubIOExternalTest.java    |   8 +-
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java |   2 -
 settings.gradle                                    |   4 +
 46 files changed, 872 insertions(+), 649 deletions(-)
 delete mode 100644 runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java
 create mode 100644 runners/flink/1.10/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
 copy runners/flink/{1.10 => 1.11}/build.gradle (84%)
 copy runners/flink/{1.9 => 1.11}/job-server-container/build.gradle (100%)
 copy runners/flink/{1.10 => 1.11}/job-server/build.gradle (95%)
 copy runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/package-info.java => 1.11/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java} (62%)
 create mode 100644 runners/flink/1.11/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
 copy runners/flink/{1.8 => 1.11}/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java (69%)
 copy runners/flink/{src/main/java/org/apache/beam/runners/flink/FlinkStateBackendFactory.java => 1.11/src/test/java/org/apache/beam/runners/flink/SourceTransformationCompat.java} (67%)
 copy runners/flink/{src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/package-info.java => 1.8/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java} (62%)
 create mode 100644 runners/flink/1.8/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTestCompat.java
 copy runners/flink/{src/main/java/org/apache/beam/runners/flink/package-info.java => 1.8/src/test/java/org/apache/beam/runners/flink/SourceTransformationCompat.java} (68%)
 rename runners/flink/{1.8 => }/src/test/java/org/apache/beam/runners/flink/FlinkRunnerTest.java (90%)