This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/sdks/github.com/nats-io/nats-server/v2-2.10.16
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 7319b65d8cb Bump github.com/nats-io/nats-server/v2 from 2.10.12 to
2.10.16 in /sdks
add 970a3f52680 Add RetryCallable mechanism for remote calls (#31539)
add 1037edec0dd Expose GroupIntoBatches parameters for WriteFiles and
TextIO (#31617)
add 911c525348b Fix nullable array issue 31674 in
AvroGenericRecordToStorageApiProto (#31675)
add 91e10cc94bc publish deploy-python-pipeline-on-flink-runner
add d26211b62c2 remove whitespaces
add 2ec9ef84202 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 081c245f968 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 5c114dfe00b Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 028e0ca42ed Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add a4939e24bf0 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 6049179867a Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 3a2b04e5f3d Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 1d5b692aabb Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add a920fd4c128 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 5545c95bc9e Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 1ccfcea11bc Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add aff48598624 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 1a9590472e0 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add cb490d4ab20 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 83e8760a916 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 6fd6b203fc0 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 04b515f375a Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 5ca0396edda Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add f0045c3519d Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 4a953366925 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 6551da20852 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 40bc6f9fac5 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add 07566c53376 Update
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
add cc374f15fca Apply suggestions from code review
add ce19c323cff Apply suggestions from code review
add 7d5b3ee171d change python code block
add c1c853fcc52 Merge pull request #31655 from jaehyeon-kim/master
add 90d3f8a177f Fixes a regression related to BQ read transform upgrad via
the TransformService (#31685)
add b482337b82e Add Storage API streaming max retries parameter for
BigQueryOptions (#31683)
add 50b71d5cacb Add Histogram combiner (#31379)
add 4a5eaf21961 Bump github.com/go-sql-driver/mysql from 1.8.0 to 1.8.1 in
/sdks (#31688)
add 83b532807b0 Blog and site updates for Beam 2.57.0 release
add 46b0a71ca5b Merge pull request #31667: Blog and site updates for Beam
2.57.0 release
add 2f517188fa8 Try mkdir for final destination before in WriteFiles
(#31690)
add 17a7b3ef398 Bump cloud.google.com/go/datastore from 1.17.0 to 1.17.1
in /sdks (#31695)
add 8ec0de58f85 Bump github.com/spf13/cobra from 1.8.0 to 1.8.1 in /sdks
(#31612)
add 1b33b958730 Bump github.com/nats-io/nats-server/v2 from 2.10.12 to
2.10.16 in /sdks
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (7319b65d8cb)
\
N -- N -- N
refs/heads/dependabot/go_modules/sdks/github.com/nats-io/nats-server/v2-2.10.16
(1b33b958730)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +-
build.gradle.kts | 1 +
sdks/go.mod | 6 +-
sdks/go.sum | 14 +-
.../main/java/org/apache/beam/sdk/io/TextIO.java | 72 ++
.../java/org/apache/beam/sdk/io/WriteFiles.java | 80 +-
.../org/apache/beam/sdk/io/TextIOWriteTest.java | 41 +
.../org/apache/beam/sdk/io/WriteFilesTest.java | 22 +
.../solace => extensions/combiners}/build.gradle | 25 +-
.../beam/sdk/extensions/combiners/Histogram.java | 569 ++++++++++++++
.../sdk/extensions/combiners/package-info.java | 19 +
.../sdk/extensions/combiners/HistogramTest.java | 403 ++++++++++
.../AvroGenericRecordToStorageApiProto.java | 5 +-
.../sdk/io/gcp/bigquery/BigQueryIOTranslation.java | 12 +-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 8 +
.../StorageApiWriteRecordsInconsistent.java | 3 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 10 +-
.../bigquery/StorageApiWritesShardedRecords.java | 15 +-
.../AvroGenericRecordToStorageApiProtoTest.java | 99 ++-
sdks/java/io/solace/build.gradle | 5 +-
.../beam/sdk/io/solace/RetryCallableManager.java | 130 ++++
.../sdk/io/solace/RetryCallableManagerTest.java | 169 ++++
sdks/python/apache_beam/io/fileio.py | 8 +
settings.gradle.kts | 2 +
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.57.0.md | 214 +++++
.../blog/deploy-python-pipeline-on-flink-runner.md | 857 +++++++++++++++++++++
.../www/site/content/en/get-started/downloads.md | 13 +-
website/www/site/data/authors.yml | 3 +
.../flink-ui.png | Bin 0 -> 75303 bytes
.../kafka-topics-1.png | Bin 0 -> 36952 bytes
.../kafka-topics-2.png | Bin 0 -> 40346 bytes
.../kafka-ui.png | Bin 0 -> 40877 bytes
.../output-topic-messages.png | Bin 0 -> 87544 bytes
34 files changed, 2736 insertions(+), 73 deletions(-)
copy sdks/java/{io/solace => extensions/combiners}/build.gradle (52%)
create mode 100644
sdks/java/extensions/combiners/src/main/java/org/apache/beam/sdk/extensions/combiners/Histogram.java
create mode 100644
sdks/java/extensions/combiners/src/main/java/org/apache/beam/sdk/extensions/combiners/package-info.java
create mode 100644
sdks/java/extensions/combiners/src/test/java/org/apache/beam/sdk/extensions/combiners/HistogramTest.java
create mode 100644
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/RetryCallableManager.java
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/RetryCallableManagerTest.java
create mode 100644 website/www/site/content/en/blog/beam-2.57.0.md
create mode 100644
website/www/site/content/en/blog/deploy-python-pipeline-on-flink-runner.md
create mode 100644
website/www/site/static/images/blog/deploy-python-pipeline-on-flink-runner/flink-ui.png
create mode 100644
website/www/site/static/images/blog/deploy-python-pipeline-on-flink-runner/kafka-topics-1.png
create mode 100644
website/www/site/static/images/blog/deploy-python-pipeline-on-flink-runner/kafka-topics-2.png
create mode 100644
website/www/site/static/images/blog/deploy-python-pipeline-on-flink-runner/kafka-ui.png
create mode 100644
website/www/site/static/images/blog/deploy-python-pipeline-on-flink-runner/output-topic-messages.png
