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 3ff66d38c41 Add relative median threshold filtering to perf alert tool
(#28237)
add 325efced65d Return new ReflectData for both reflect datum reader and
writer (#28280)
add 5221fde659a Add Speech Emotion Recognition TensorFlow Notebook (#28172)
add 0b4302e5f95 [Documentation] Update docs to run SparkPipelineRunner on
a Kubernetes cluster (closes #27984)
add 3591283d722 Fix a couple notebook typos (#28166)
add 3c93f7d17ba Feature/add warnings to file watchers (#28206)
add dc16aa386fe Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#28278)
add 06cdd5ef1f7 Add PostCommit Go VR Samza action (#28251)
add 3463aa3fde5 [prism] Fail jobs on SDK disconnect. (#28193)
add 6b3ce095b0a Reduce the maximum size of input splits in Flink to better
distribute work (#28045)
add 6d5048e0508 Add ARM test suite trigger commands to mass comment script
(#27982)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 1 +
...mit_RAT.yml => beam_PostCommit_Go_VR_Samza.yml} | 44 +-
.../beam-ml/nlp_tensorflow_streaming.ipynb | 6 +-
.../beam-ml/speech_emotion_tensorflow.ipynb | 2159 ++++++++++++++++++++
release/src/main/scripts/github_actions_jobs.txt | 8 +
release/src/main/scripts/mass_comment.py | 20 +-
.../beam/runners/flink/FlinkPipelineOptions.java | 7 +
.../translation/wrappers/SourceInputFormat.java | 22 +-
sdks/go.mod | 4 +-
sdks/go.sum | 6 +-
.../prism/internal/engine/elementmanager.go | 17 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 43 +-
.../beam/runners/prism/internal/jobservices/job.go | 12 +-
.../prism/internal/jobservices/management.go | 2 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 31 +-
.../beam/runners/prism/internal/worker/bundle.go | 24 +-
.../runners/prism/internal/worker/bundle_test.go | 2 +-
.../beam/runners/prism/internal/worker/worker.go | 85 +-
.../runners/prism/internal/worker/worker_test.go | 10 +-
sdks/go/pkg/beam/testing/passert/equals_test.go | 2 +-
.../main/java/org/apache/beam/sdk/io/FileIO.java | 9 +
.../sdk/extensions/avro/io/AvroDatumFactory.java | 25 +-
sdks/python/apache_beam/io/fileio.py | 12 +
.../site/content/en/documentation/runners/spark.md | 47 +-
24 files changed, 2456 insertions(+), 142 deletions(-)
copy .github/workflows/{beam_PreCommit_RAT.yml =>
beam_PostCommit_Go_VR_Samza.yml} (68%)
create mode 100644 examples/notebooks/beam-ml/speech_emotion_tensorflow.ipynb
create mode 100644 release/src/main/scripts/github_actions_jobs.txt
