This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from b2960c9db3e fix(website): Use standard method for CSP frame-src
exceptions (#36653)
add 020335ee23b Fixed KafkaIO Python perf test: use existing kafka-cluster
config, fix broker setup, and correct test arguments
add 50477d8bd9b ix KafkaIO perf test assertion logic
add b9ec235e5ec fixed linting
add 54e4dcf737f Fixed the pylint error
add f5416c2bcc7 Fixed the YAPF formatting issue
add 8b2657bf80d fixed kafka stress tests
add 263510afbfd Fix Kafka stress test: remove invalid param
add ab4a80ddd22 fixed formatting
add f8c8dda8ed4 removed invalid params
add 0e4ac08e4b1 Merge pull request #36633 from
aIbrahiim/30960-performance-tests-xlang-kafka--python
add 1b34a6d7571 Bump go.mongodb.org/mongo-driver from 1.17.4 to 1.17.6 in
/sdks (#36659)
add 86bc45286d1 fixed issue in python precommit (#36561)
add 0697e54a543 Kerberos Authentication for KafkaIO (#36099)
add 1c5f0f3a505 Revert "Force logback version in transitive dependencies"
(#36649)
add 55880d361a5 Split ViewTest (#36655)
add 190f21e6e5e Ensure consistent behavior between streaming and batch
order window elements (#36661)
add 69685250777 Bump cloud.google.com/go/spanner from 1.86.0 to 1.86.1 in
/sdks (#36645)
add 74576946753 Bump cloud.google.com/go/bigtable from 1.39.0 to 1.40.1 in
/sdks (#36448)
add 8481373fed5 Fix typo in release notes (#36651)
add 8c626494d3a Bump cloud.google.com/go/datastore from 1.20.0 to 1.21.0
in /sdks (#36627)
add b976b515c4e Change ExecutionStateSampler.ExecutionState to support a
scopedActivate method. From benchmarks this is no additional overhead and it is
easier to use. (#36646)
No new revisions were added by this update.
Summary of changes:
.../beam_PerformanceTests_xlang_KafkaIO_Python.yml | 82 +-
.../workflows/beam_StressTests_Java_KafkaIO.yml | 77 +-
.../kafka-cluster/03-zookeeper/50pzoo.yml | 121 +--
.../kubernetes/kafka-cluster/05-kafka/50kafka.yml | 156 ++--
CHANGES.md | 4 +-
build.gradle.kts | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 6 -
contributor-docs/python-tips.md | 12 +-
.../java/org/apache/beam/it/kafka/KafkaIOST.java | 28 +-
sdks/go.mod | 8 +-
sdks/go.sum | 16 +-
.../transforms/{ViewTest.java => MapViewTest.java} | 884 +------------------
.../org/apache/beam/sdk/transforms/ViewTest.java | 951 ---------------------
.../{sbe => kafka-factories}/build.gradle | 27 +-
.../kafka/factories/FileAwareFactoryFn.java | 258 ++++++
.../kafka/factories/KerberosConsumerFactoryFn.java | 150 ++++
.../extensions/kafka/factories}/package-info.java | 4 +-
.../kafka/factories/FileAwareFactoryFnTest.java | 268 ++++++
.../factories/KerberosConsumerFactoryFnTest.java | 242 ++++++
.../control/ExecutionStateSamplerBenchmark.java | 17 +
.../fn/harness/control/ExecutionStateSampler.java | 19 +
.../fn/harness/control/ProcessBundleHandler.java | 5 +-
.../harness/data/PCollectionConsumerRegistry.java | 10 +-
.../harness/data/PTransformFunctionRegistry.java | 5 +-
.../harness/control/ExecutionStateSamplerTest.java | 140 +--
.../harness/logging/BeamFnLoggingClientTest.java | 6 +-
.../cookbook/ordered_window_elements/streaming.py | 39 +-
.../ordered_window_elements/streaming_test.py | 212 +++--
.../io/external/xlang_kafkaio_perf_test.py | 10 +-
sdks/python/scripts/run_pytest.sh | 2 +-
sdks/python/test-suites/tox/common.gradle | 5 +-
settings.gradle.kts | 1 +
website/www/site/content/en/blog/beam-2.69.0.md | 4 +-
33 files changed, 1558 insertions(+), 2212 deletions(-)
copy
sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/{ViewTest.java =>
MapViewTest.java} (54%)
copy sdks/java/extensions/{sbe => kafka-factories}/build.gradle (53%)
create mode 100644
sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/FileAwareFactoryFn.java
create mode 100644
sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories/KerberosConsumerFactoryFn.java
copy
{.test-infra/mock-apis/src/main/java/org/apache/beam/testinfra/mockapis/echo/v1
=>
sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories}/package-info.java
(85%)
create mode 100644
sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/extensions/kafka/factories/FileAwareFactoryFnTest.java
create mode 100644
sdks/java/extensions/kafka-factories/src/test/java/org/apache/beam/sdk/extensions/kafka/factories/KerberosConsumerFactoryFnTest.java
