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 a6917d410d3 Add no-cache-dir to tox install (#29024)
add d32a8e55183 Update the Beam ML readme (#29031)
add 48ad7e338b7 Fix registry (#29013)
add 2a764dd2a05 Change upload test report step (#29036)
add 83355135b42 Add raw format option.
add 5bfd422c8d7 Timestamp and id attributes.
add 0940e900681 Attribute handling.
add 868f06da01d Add configurable error handling.
add 784e9278b15 guava
add f12f529882d cleanup
add ef97c4d61f9 Merge pull request #28782 [YAML] Java PubSubIO
add bde60059f09 Log warning when gen_protos is not found (#29025)
add 0b50a173608 Fix num workers (#29006)
add f8ca45ebb7b [Website] add linkedin case-study
add 36574ce3109 [Website] add linkedIn case-study (#28988)
add 5f1659af9ab Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#29032)
add 3097f50230a Bump cloud.google.com/go/datastore from 1.14.0 to 1.15.0
in /sdks (#28910)
add ce28a36d23f Add cleanup stale k8s namespace to CleanUpGCPResource
workflow (#29038)
add 587fa177b69 Fix beam_LoadTests_Go_GBK_Dataflow_Batch job (#28960)
add 67c30a447cf Fix bug causing job failure (#28982)
add 416a4f268a2 [RRIO] [Call] Create CallShouldBackoff and default
implementation (#28952)
add eb7997145e4 [RRIO] [Cache] Stub CacheRead transform (#29011)
add 89115954f67 Rename rrio package (#29040)
No new revisions were added by this update.
Summary of changes:
.github/workflows/beam_CancelStaleDataflowJobs.yml | 2 -
.github/workflows/beam_CleanUpGCPResources.yml | 2 -
.../workflows/beam_CleanUpPrebuiltSDKImages.yml | 2 -
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 2 +
.../beam_LoadTests_Go_GBK_Dataflow_Batch.yml | 43 ++--
.../beam_PostCommit_Java_PVR_Spark_Batch.yml | 21 +-
.../beam_PreCommit_Java_PVR_Flink_Batch.yml | 11 +-
.../beam_PreCommit_Java_PVR_Flink_Docker.yml | 2 +-
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 2 +-
.../workflows/beam_Publish_Docker_Snapshots.yml | 4 +-
...enet_Classification_Resnet_152_Tesla_T4_GPU.txt | 2 +-
...tch_100b.txt => go_GBK_Dataflow_Batch_100b.txt} | 9 +-
...h_100kb.txt => go_GBK_Dataflow_Batch_100kb.txt} | 9 +-
...Batch_10b.txt => go_GBK_Dataflow_Batch_10b.txt} | 9 +-
...ut_4.txt => go_GBK_Dataflow_Batch_Fanout_4.txt} | 9 +-
...ut_8.txt => go_GBK_Dataflow_Batch_Fanout_8.txt} | 9 +-
... => go_GBK_Dataflow_Batch_Reiteration_10KB.txt} | 9 +-
...t => go_GBK_Dataflow_Batch_Reiteration_2MB.txt} | 9 +-
.test-infra/tools/build.gradle | 12 +-
.test-infra/tools/stale_k8s_workload_cleaner.sh | 49 ++++
examples/notebooks/beam-ml/README.md | 10 +-
sdks/go.mod | 6 +-
sdks/go.sum | 12 +-
.../main/java/org/apache/beam/sdk/values/Row.java | 8 +-
.../PubsubReadSchemaTransformConfiguration.java | 60 +++++
.../pubsub/PubsubReadSchemaTransformProvider.java | 192 ++++++++++----
.../PubsubWriteSchemaTransformConfiguration.java | 51 ++++
.../pubsub/PubsubWriteSchemaTransformProvider.java | 162 ++++++++++--
.../PubsubReadSchemaTransformProviderTest.java | 96 +++++++
sdks/java/io/rrio/build.gradle | 2 +-
.../ApiIOError.java | 2 +-
.../CacheRead.java} | 32 +--
.../CacheWrite.java | 4 +-
.../CallShouldBackoff.java} | 16 +-
...llShouldBackoffBasedOnRejectionProbability.java | 103 ++++++++
.../Caller.java | 2 +-
.../RequestResponseIO.java | 4 +-
.../SetupTeardown.java | 2 +-
.../UserCodeExecutionException.java | 2 +-
.../UserCodeQuotaException.java | 2 +-
.../UserCodeTimeoutException.java | 2 +-
.../package-info.java | 2 +-
...ouldBackoffBasedOnRejectionProbabilityTest.java | 92 +++++++
.../CallerTest.java | 2 +-
.../SetupTeardownTest.java | 2 +-
sdks/python/setup.py | 18 ++
.../www/site/content/en/case-studies/linkedin.md | 284 ++++++++++++++++++++-
website/www/site/data/en/quotes.yaml | 5 +
.../images/case-study/linkedin/bingfeng-xia.jpg | Bin 0 -> 99417 bytes
.../static/images/case-study/linkedin/scheme-1.png | Bin 0 -> 72662 bytes
.../static/images/case-study/linkedin/scheme-2.png | Bin 0 -> 91660 bytes
.../static/images/case-study/linkedin/scheme-3.png | Bin 0 -> 207951 bytes
.../static/images/case-study/linkedin/scheme-4.png | Bin 0 -> 98569 bytes
.../static/images/case-study/linkedin/scheme-5.png | Bin 0 -> 116720 bytes
.../static/images/case-study/linkedin/scheme-6.png | Bin 0 -> 26758 bytes
.../images/case-study/linkedin/xinyu-liu.jpg | Bin 0 -> 100350 bytes
56 files changed, 1168 insertions(+), 224 deletions(-)
rename .github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_100b.txt
=> go_GBK_Dataflow_Batch_100b.txt} (76%)
rename .github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_100kb.txt
=> go_GBK_Dataflow_Batch_100kb.txt} (76%)
rename .github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_10b.txt
=> go_GBK_Dataflow_Batch_10b.txt} (76%)
rename
.github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_Fanout_4.txt =>
go_GBK_Dataflow_Batch_Fanout_4.txt} (76%)
rename
.github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_Fanout_8.txt =>
go_GBK_Dataflow_Batch_Fanout_8.txt} (76%)
rename
.github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_Reiteration_10KB.txt
=> go_GBK_Dataflow_Batch_Reiteration_10KB.txt} (77%)
rename
.github/workflows/load-tests-job-configs/{config_GBK_Go_Batch_Reiteration_2MB.txt
=> go_GBK_Dataflow_Batch_Reiteration_2MB.txt} (77%)
create mode 100755 .test-infra/tools/stale_k8s_workload_cleaner.sh
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/ApiIOError.java (97%)
copy
sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio/CacheWrite.java
=> requestresponse/CacheRead.java} (75%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/CacheWrite.java (97%)
copy
sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio/Caller.java
=> requestresponse/CallShouldBackoff.java} (63%)
create mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbability.java
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/Caller.java (96%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/RequestResponseIO.java (98%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/SetupTeardown.java (96%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/UserCodeExecutionException.java (96%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/UserCodeQuotaException.java (96%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/UserCodeTimeoutException.java (96%)
rename sdks/java/io/rrio/src/main/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/package-info.java (95%)
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbabilityTest.java
rename sdks/java/io/rrio/src/test/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/CallerTest.java (98%)
rename sdks/java/io/rrio/src/test/java/org/apache/beam/io/{requestresponseio
=> requestresponse}/SetupTeardownTest.java (98%)
create mode 100644
website/www/site/static/images/case-study/linkedin/bingfeng-xia.jpg
create mode 100644
website/www/site/static/images/case-study/linkedin/scheme-1.png
create mode 100644
website/www/site/static/images/case-study/linkedin/scheme-2.png
create mode 100644
website/www/site/static/images/case-study/linkedin/scheme-3.png
create mode 100644
website/www/site/static/images/case-study/linkedin/scheme-4.png
create mode 100644
website/www/site/static/images/case-study/linkedin/scheme-5.png
create mode 100644
website/www/site/static/images/case-study/linkedin/scheme-6.png
create mode 100644
website/www/site/static/images/case-study/linkedin/xinyu-liu.jpg
