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 31988c8 (commit)
to d8c5da8 (commit)
from 31988c8 Merge pull request #14898 from boyuanzz/fix
add 331c67c [BEAM-12384] Refine generic types on Read.Bounded internals
add 3b705c1 [BEAM-12384] Set output typeDescriptor explictly in
Read.Bounded transform
add 83bccf9 [BEAM-12384] Infer typeDescriptor from coder if
typeDescriptor is not set explicitly.
add b03e429 Merge pull request #14854: [BEAM-12384] Set output
typeDescriptor explictly in Read.Bounded transform
add b6fca2b [BEAM-12415] Update Spark 3 version to 3.1.2
add 2516cac Merge pull request #14897: [BEAM-12415] Update Spark 3
version to 3.1.2
add b342805 [BEAM-12277] Add flink 1.13 build target.
add 8ad8965 [BEAM-12277] Make Flink 1.13 the default Flink version to run
the tests
add 8be1cb1 [BEAM-12277] Update expected metric name formatting.
add 881da20 [BEAM-12277] fix mistake in source overrides
add 00eb420 Merge pull request #14719: [BEAM-12277] Add Flink 1.13 build
target.
add 79d4c03 [BEAM-11988] added a fix for missing sample.txt (#14889)
add dd15d59 [BEAM-621] Add MapKeys, MapValues transforms (#14273)
add d8c5da8 [BEAM-11608] Development environment set up automation
(#14584)
No new revisions were added by this update.
Summary of changes:
.github/workflows/local_env_tests.yml | 55 ++++++
.test-infra/jenkins/CommonTestProperties.groovy | 2 +-
CHANGES.md | 1 +
dev-support/docker/Dockerfile | 33 +---
.../.coveragerc => dev-support/docker/pkglist | 30 +++-
gradle.properties | 2 +-
local-env-setup.sh | 128 ++++++++++++++
runners/flink/{1.12 => 1.13}/build.gradle | 8 +-
.../job-server-container/build.gradle | 0
.../flink/{1.10 => 1.13}/job-server/build.gradle | 2 +-
.../runners/flink/streaming/StreamSources.java | 0
.../beam/runners/flink/metrics/FileReporter.java | 8 +-
runners/spark/3/build.gradle | 2 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 56 +++---
.../org/apache/beam/sdk/transforms/MapKeys.java | 163 ++++++++++++++++++
.../org/apache/beam/sdk/transforms/MapValues.java | 164 ++++++++++++++++++
.../beam/sdk/transforms/SimpleMapWithFailures.java | 75 +++++++++
.../org/apache/beam/sdk/values/PCollection.java | 8 +-
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 43 +++++
.../apache/beam/sdk/transforms/MapKeysTest.java | 119 +++++++++++++
.../apache/beam/sdk/transforms/MapValuesTest.java | 119 +++++++++++++
.../python/apache_beam/options/pipeline_options.py | 2 +-
.../runners/portability/flink_runner_test.py | 49 +++---
settings.gradle.kts | 4 +
.../site/content/en/documentation/runners/flink.md | 24 ++-
.../site/content/en/get-started/quickstart-java.md | 187 ++++++++++++---------
26 files changed, 1107 insertions(+), 177 deletions(-)
create mode 100644 .github/workflows/local_env_tests.yml
copy sdks/python/.coveragerc => dev-support/docker/pkglist (74%)
create mode 100755 local-env-setup.sh
copy runners/flink/{1.12 => 1.13}/build.gradle (84%)
copy runners/flink/{1.12 => 1.13}/job-server-container/build.gradle (100%)
copy runners/flink/{1.10 => 1.13}/job-server/build.gradle (95%)
copy runners/flink/{1.12 =>
1.13}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(100%)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapKeys.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapValues.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SimpleMapWithFailures.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MapKeysTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/MapValuesTest.java
