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/10/21 03:37:01 UTC
[beam] tag nightly-master updated (4d1c2af -> 9c8939b)
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 4d1c2af (commit)
to 9c8939b (commit)
from 4d1c2af Merge pull request #15750 from [BEAM-13077][Playground] LifeCycle.CreateFolders() after several uses returns error
add 8578c9a [BEAM-13079] Updates cross-language transform URNs to use the new convention (#15748)
add 6bfd83d [BEAM-10990] Adds response filtering for ElasticsearchIO
add f7691e6 [BEAM-5172] Tries to reduce ES uTest flakiness
add a05aa45 Merge pull request #15381 from egalpin/BEAM-10990-elasticsearch-response-filtering
add b8ed280 Add -XX:+AlwaysActAsServerClassMachine to Java SDK container
add 59f41e5 Merge pull request #15739: [BEAM-13073] Fixes Unexpected GC when using Java 11
add c5b367c adhoc: Minor update to flink runner docs
add 76535e7 Minor: corrections to flink runner docs (#15759)
add 070ea22 [BEAM-11087] Add default WindowMappingFn from Main to Side Input windows, validation test, unit tests (#15743)
add 9c8939b [BEAM-13082] Re-use dataWriter buffer. (#15762)
No new revisions were added by this update.
Summary of changes:
sdks/go/pkg/beam/core/runtime/exec/sideinput.go | 11 +-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 50 ++-
sdks/go/pkg/beam/core/runtime/exec/window.go | 22 +-
sdks/go/pkg/beam/core/runtime/exec/window_test.go | 50 +++
sdks/go/pkg/beam/core/runtime/graphx/translate.go | 25 +-
sdks/go/pkg/beam/core/runtime/harness/datamgr.go | 11 +-
.../pkg/beam/core/runtime/harness/datamgr_test.go | 55 +++
sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go | 4 +-
sdks/go/pkg/beam/pardo.go | 12 +-
sdks/go/test/integration/integration.go | 2 +
sdks/go/test/integration/primitives/windowinto.go | 51 +++
.../test/integration/primitives/windowinto_test.go | 7 +
sdks/java/container/boot.go | 1 +
.../ExternalSchemaIOTransformRegistrar.java | 6 +-
.../io/debezium/DebeziumTransformRegistrar.java | 2 +-
.../elasticsearch-tests-5/build.gradle | 4 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 26 +-
.../elasticsearch-tests-6/build.gradle | 4 +
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 26 +-
.../elasticsearch-tests-7/build.gradle | 6 +-
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 26 +-
.../elasticsearch/ElasticsearchIOTestCommon.java | 184 +++++++--
.../io/elasticsearch/ElasticsearchIOTestUtils.java | 26 +-
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 456 +++++++++++++++++----
.../beam/sdk/io/gcp/pubsub/ExternalRead.java | 2 +-
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 2 +-
.../io/gcp/spanner/SpannerTransformRegistrar.java | 12 +-
.../sdk/io/gcp/pubsub/PubsubIOExternalTest.java | 4 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 6 +-
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 11 +-
.../sdk/io/kinesis/KinesisTransformRegistrar.java | 4 +-
.../crosslanguage/SnowflakeTransformRegistrar.java | 4 +-
sdks/python/apache_beam/io/debezium.py | 2 +-
sdks/python/apache_beam/io/external/gcp/pubsub.py | 4 +-
sdks/python/apache_beam/io/gcp/spanner.py | 12 +-
sdks/python/apache_beam/io/jdbc.py | 4 +-
sdks/python/apache_beam/io/kafka.py | 8 +-
sdks/python/apache_beam/io/kinesis.py | 4 +-
sdks/python/apache_beam/io/snowflake.py | 4 +-
.../site/content/en/documentation/runners/flink.md | 4 +-
40 files changed, 984 insertions(+), 170 deletions(-)