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 69cd6ef06b3 Bump github.com/tetratelabs/wazero from 1.2.0 to 1.2.1 in
/sdks (#27162)
add 392a8fe5880 Bump actions/setup-go from 3 to 4 (#27110)
add ae8510d1feb [website] #27115 Add supported Flink versions (#27117)
add 7a4cbc18f97 Bump github.com/aws/aws-sdk-go-v2/service/s3 in /sdks
(#27172)
add 4c66866aa95 Avro datum factory fixup (#27173)
add 1c12f92a9a5 Add initial DLQ router (#27045)
add 42d0a6e3564 Fix locking race between duplicate PartitionRecords w
matching uid (#27055)
add e4a0a275578 Change default work remaining to 0.0 instead of 1.0
(#27032)
add ef24b6a0aa2 [Code Completion Plugin] Define Element Pattern for java
sdk
add 08d49f0e0eb Merge pull request #27093 from
sultanalieva-s/code-completion-plugin-element-pattern
add f7dcb5973aa obsolete action removed (#27143)
add f1adfdd7f24 Issue26977 changing sdk bug (#26978)
add f2240ffd9c5 [Website] add project shield case study (#27087)
add 5e942ae3790 Ensure that the BeamFnLoggingClient terminates process if
stream breaks (#25186)
No new revisions were added by this update.
Summary of changes:
.github/workflows/beam_PreCommit_Go.yml | 2 +-
.github/workflows/go_tests.yml | 2 +-
.github/workflows/local_env_tests.yml | 4 +-
.github/workflows/playground_frontend_test.yml | 2 +-
.github/workflows/python_tests.yml | 2 +-
.github/workflows/tour_of_beam_backend.yml | 2 +-
.../workflows/tour_of_beam_backend_integration.yml | 2 +-
.github/workflows/tour_of_beam_examples_ci.yml | 47 ---
.github/workflows/tour_of_beam_frontend_test.yml | 4 +-
.../cloudbuild/scripts/tob_deploy_infra_backend.sh | 5 +-
.../frontend/integration_test/tour_page_test.dart | 101 +++++
.../frontend/lib/cache/unit_content.dart | 2 +-
.../tour-of-beam/frontend/lib/models/node.dart | 11 +-
.../frontend/lib/pages/tour/state.dart | 43 +-
learning/tour-of-beam/frontend/pubspec.lock | 2 +-
learning/tour-of-beam/frontend/pubspec.yaml | 2 +-
playground/frontend/Dockerfile | 2 +-
.../frontend/playground_components/pubspec.yaml | 2 +-
.../playground_components_dev/pubspec.yaml | 2 +-
playground/frontend/pubspec.lock | 2 +-
playground/frontend/pubspec.yaml | 2 +-
.../beam-code-completion-plugin/build.gradle.kts | 1 +
...KPattern.java => BeamCompletionConfidence.java} | 19 +-
.../src/main/java/BeamCompletionContributor.java | 81 +++-
.../src/main/resources/META-INF/plugin.xml | 4 +-
.../java/BeamCompletionContributorTestCase.java | 60 +++
.../testData/TestCompletions.java} | 30 +-
.../TestCompletionsWrongClass.java} | 21 +-
.../testData/TestCompletionsWrongMethod.java} | 29 +-
.../util/AvroCoderCloudObjectTranslator.java | 30 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 2 +-
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 4 +-
.../sdk/transforms/reflect/DoFnInvokersTest.java | 2 +-
.../extensions/avro/schemas/utils/AvroUtils.java | 3 +-
.../beam/sdk/fn/stream/DirectStreamObserver.java | 24 +-
.../jmh/logging/BeamFnLoggingClientBenchmark.java | 2 +-
.../java/org/apache/beam/fn/harness/FnHarness.java | 7 +-
.../fn/harness/control/BeamFnControlClient.java | 5 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 454 +++++++++++++--------
.../harness/control/BeamFnControlClientTest.java | 4 +-
.../harness/logging/BeamFnLoggingClientTest.java | 200 ++++++++-
sdks/java/io/components/build.gradle | 41 ++
.../io/components/deadletterqueue/DLQRouter.java | 55 +++
.../deadletterqueue/sinks/ThrowingSink.java | 45 ++
.../components/deadletterqueue/DLQRouterTest.java | 75 ++++
.../changestreams/dao/MetadataTableDao.java | 10 +-
.../changestreams/dao/MetadataTableDaoTest.java | 53 ++-
.../site/content/en/case-studies/projectShield.md | 231 +++++++++++
.../site/content/en/documentation/runners/flink.md | 87 +++-
website/www/site/data/en/quotes.yaml | 5 +
.../apache_beam_streaming_log_analytics.png | Bin 0 -> 93797 bytes
.../case-study/projectShield/chad_hansen.png | Bin 0 -> 386079 bytes
.../case-study/projectShield/marc_howard.jpg | Bin 0 -> 136851 bytes
.../projectShield/project_shield_mechanism.png | Bin 0 -> 29786 bytes
.../images/logos/powered-by/project_shield.png | Bin 0 -> 9908 bytes
57 files changed, 1453 insertions(+), 380 deletions(-)
delete mode 100644 .github/workflows/tour_of_beam_examples_ci.yml
copy
plugins/beam-code-completion-plugin/src/main/java/{BeamJavaSDKPattern.java =>
BeamCompletionConfidence.java} (62%)
create mode 100644
plugins/beam-code-completion-plugin/src/test/java/BeamCompletionContributorTestCase.java
copy
plugins/beam-code-completion-plugin/src/{main/java/BeamJavaSDKPattern.java =>
test/testData/TestCompletions.java} (53%)
rename
plugins/beam-code-completion-plugin/src/test/{java/BeamCompletionContributorTestcase.java
=> testData/TestCompletionsWrongClass.java} (55%)
rename
plugins/beam-code-completion-plugin/src/{main/java/BeamJavaSDKPattern.java =>
test/testData/TestCompletionsWrongMethod.java} (54%)
create mode 100644 sdks/java/io/components/build.gradle
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/deadletterqueue/DLQRouter.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/deadletterqueue/sinks/ThrowingSink.java
create mode 100644
sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/deadletterqueue/DLQRouterTest.java
create mode 100644 website/www/site/content/en/case-studies/projectShield.md
create mode 100644
website/www/site/static/images/case-study/projectShield/apache_beam_streaming_log_analytics.png
create mode 100644
website/www/site/static/images/case-study/projectShield/chad_hansen.png
create mode 100644
website/www/site/static/images/case-study/projectShield/marc_howard.jpg
create mode 100644
website/www/site/static/images/case-study/projectShield/project_shield_mechanism.png
create mode 100644
website/www/site/static/images/logos/powered-by/project_shield.png
