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 f64aec237c2 Adjust JVM heap size for extremely large memory machine
(#31567)
add cbc480eba20 Bump cloud.google.com/go/bigtable from 1.22.0 to 1.25.0 in
/sdks (#31681)
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
No new revisions were added by this update.
Summary of changes:
sdks/go.mod | 52 +-
sdks/go.sum | 1292 +++++++++++++++++++-
.../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 +
.../AvroGenericRecordToStorageApiProto.java | 5 +-
.../AvroGenericRecordToStorageApiProtoTest.java | 99 +-
sdks/java/io/solace/build.gradle | 5 +-
.../beam/sdk/io/solace/RetryCallableManager.java | 130 ++
.../sdk/io/solace/RetryCallableManagerTest.java | 169 +++
.../blog/deploy-python-pipeline-on-flink-runner.md | 857 +++++++++++++
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
18 files changed, 2716 insertions(+), 111 deletions(-)
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/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
