This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/npm_and_yarn/sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/ws-6.2.3
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 8569c40d5db Bump ws
add 3d05eec17d4 Update bigquery.py (#31620)
add b058f0fcbd1 Add SolaceCheckpointMark for handling Solace checkpointing
(#31621)
add ef885399c92 CassandraIO: Fix generic SelectAll clauses provided by
ValueProvider<String> causing CassandraIO.read to fail (#31623)
add 96b9de0fee9 Solace Read connector: UnboundedSource and UnboundedReader
(#31636)
add 2b9078506ca Add interfaces for broker-helper classes (#31635)
add 33267eae7d9 warn when using auto_unique_labels (#31551)
add 3ed91c880f8 Update build_release_candidate.yml (#31638)
add aabf7d0fb46 Bump scikit-learn from 1.0.2 to 1.5.0 in
/sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline
(#31629)
add 9379df192be Use correct name for tox doc task.
add 8e308cd666f Merge pull request #31643: Use correct name for tox doc
task.
add eaea331981c Add counters for bytes read/written per gcs bucket (#31498)
add 0a392e9c238 Feature add metrics counting the number of bytes
read/written from/to GCS bucket per job (#31466)
add b3bb85e909d Update the list of reviewers. (#31646)
add 0cce58f12cf Use intended version for elasticsearch tests (#31639)
add 561bf2f07e1 Fix playground examples (#31647)
add 9b0b6b6a38d Update learning-resources.md
add cfbcdf03906 Merge pull request #31654 from liferoad/patch-14
add 38e6e6cb066 Fix serialization for list type headers (#31618)
add 29285d049f0 [#31403] Relax prism constraints to allow python wordcount
to execute. (#31644)
add d61e04ad624 [YAML] Allow explicitly including external provider lists.
(#31604)
add 0445ae998ac Update beamquest.md
add e4a0208534c Merge pull request #31662 from apache/aaltay-patch-1
add c6c3fd0490a Handle MultimapKeysSideInput in State GetRequests (#31632)
add 3914ad0754d Solace Read connector: data classes and mapper (#31637)
add 999b70b0c48 Bump github.com/linkedin/goavro/v2 from 2.12.0 to 2.13.0
in /sdks (#31633)
add 3695d496701 Bump golang.org/x/net from 0.24.0 to 0.26.0 in /sdks
(#31614)
add 14fd366f0ad Add support for sharing models across steps (#31665)
add 18af8c837fa Solace Read connector (#31476)
add 0f2e1963987 Replace getElementType with getValueType for MAP in
AvroGenericRecord… (#31653)
add a944bf87cd0 Bump github.com/aws/aws-sdk-go-v2 from 1.27.2 to 1.30.0 in
/sdks (#31670)
add 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
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 832712ac053 Bump github.com/tetratelabs/wazero from 1.7.0 to 1.7.3 in
/sdks (#31672)
add bb296e46c06 Create CsvIOParseError data class (#31700)
add ba04213af09 [#28187][Prism] Relax or fix issues in Prism to allow
Python pipelines to execute. (#31694)
add 2cc2b8e4488 Bump braces from 3.0.2 to 3.0.3 in /sdks/typescript
(#31664)
add d7971689b95 Bump ws
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 (8569c40d5db)
\
N -- N -- N
refs/heads/dependabot/npm_and_yarn/sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/ws-6.2.3
(d7971689b95)
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:
.github/REVIEWERS.yml | 3 -
...beam_PreCommit_Java_ElasticSearch_IO_Direct.yml | 1 -
.github/workflows/build_release_candidate.yml | 18 +-
CHANGES.md | 4 +-
build.gradle.kts | 1 +
.../Core Transforms/GroupByKey/GroupByKey/task.py | 20 +-
sdks/go.mod | 76 +-
sdks/go.sum | 1342 ++++++++++++++++++--
sdks/go/pkg/beam/runners/prism/internal/coders.go | 25 +
.../beam/runners/prism/internal/handlerunner.go | 15 +
.../prism/internal/jobservices/management.go | 82 +-
.../pkg/beam/runners/prism/internal/preprocess.go | 5 -
sdks/go/pkg/beam/runners/prism/internal/stage.go | 18 +-
.../runners/prism/internal/unimplemented_test.go | 10 +-
.../beam/runners/prism/internal/worker/worker.go | 26 +-
.../runners/prism/internal/worker/worker_test.go | 95 ++
sdks/java/container/boot.go | 43 +-
sdks/java/container/boot_test.go | 12 +
.../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 +
.../{io/csv => extensions/combiners}/build.gradle | 12 +-
.../beam/sdk/extensions/combiners/Histogram.java | 569 +++++++++
.../sdk/extensions/combiners/package-info.java} | 11 +-
.../sdk/extensions/combiners/HistogramTest.java | 403 ++++++
.../sdk/extensions/gcp/options/GcsOptions.java | 30 +
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 109 +-
.../util/channels/CountingReadableByteChannel.java | 63 +
.../util/channels/CountingSeekableByteChannel.java | 116 ++
.../util/channels/CountingWritableByteChannel.java | 60 +
.../gcp/util/channels/package-info.java} | 10 +-
.../beam/sdk/extensions/gcp/util/GcsUtilTest.java | 131 +-
.../CountingChannelsIsOpenCloseMethodsTest.java | 105 ++
.../channels/CountingChannelsReadMethodsTest.java | 122 ++
.../channels/CountingChannelsWriteMethodsTest.java | 118 ++
.../channels/CountingSeekableByteChannelTest.java | 68 +
.../org/apache/beam/sdk/io/cassandra/ReadFn.java | 13 +-
.../beam/sdk/io/cassandra/CassandraIOTest.java | 89 ++
sdks/java/io/csv/build.gradle | 1 +
.../apache/beam/sdk/io/csv/CsvIOParseError.java | 75 ++
.../beam/sdk/io/csv/CsvIOParseErrorTest.java | 101 ++
.../elasticsearch-tests-5/build.gradle | 47 -
.../src/test/contrib/create_elk_container.sh | 24 -
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 213 ----
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 301 -----
.../src/test/resources/clientkeystore | Bin 1942 -> 0 bytes
.../elasticsearch-tests-6/build.gradle | 46 -
.../src/test/contrib/create_elk_container.sh | 24 -
.../sdk/io/elasticsearch/ElasticsearchIOIT.java | 213 ----
.../sdk/io/elasticsearch/ElasticsearchIOTest.java | 294 -----
.../src/test/resources/clientkeystore | Bin 1942 -> 0 bytes
.../elasticsearch-tests-7/build.gradle | 3 +-
.../elasticsearch-tests-8/build.gradle | 9 +-
.../elasticsearch-tests-common/build.gradle | 32 +-
.../io/elasticsearch/ElasticsearchIOITCommon.java | 1 +
.../elasticsearch/ElasticsearchIOTestCommon.java | 8 +-
.../io/elasticsearch/ElasticsearchIOTestUtils.java | 1 +
.../beam/sdk/io/elasticsearch/package-info.java} | 11 +-
.../AvroGenericRecordToStorageApiProto.java | 15 +-
.../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 | 127 ++
.../beam/sdk/io/rabbitmq/RabbitMqMessage.java | 49 +-
.../beam/sdk/io/rabbitmq/RabbitMqMessageTest.java | 76 ++
sdks/java/io/solace/build.gradle | 16 +
.../beam/sdk/io/solace/RetryCallableManager.java | 130 ++
.../org/apache/beam/sdk/io/solace/SolaceIO.java | 415 +++++-
.../beam/sdk/io/solace/broker/MessageReceiver.java | 59 +
.../beam/sdk/io/solace/broker/SempClient.java | 49 +
.../sdk/io/solace/broker/SempClientFactory.java | 11 +-
.../beam/sdk/io/solace/broker/SessionService.java | 50 +
.../io/solace/broker/SessionServiceFactory.java | 28 +-
.../org/apache/beam/sdk/io/solace/data/Solace.java | 323 ++++-
.../sdk/io/solace/read/SolaceCheckpointMark.java | 98 ++
.../sdk/io/solace/read/UnboundedSolaceReader.java | 191 +++
.../sdk/io/solace/read/UnboundedSolaceSource.java | 148 +++
.../sdk/io/solace/MockEmptySessionService.java} | 34 +-
.../apache/beam/sdk/io/solace/MockSempClient.java | 87 ++
.../beam/sdk/io/solace/MockSempClientFactory.java} | 26 +-
.../beam/sdk/io/solace/MockSessionService.java | 88 ++
.../sdk/io/solace/MockSessionServiceFactory.java} | 26 +-
.../sdk/io/solace/RetryCallableManagerTest.java | 169 +++
.../apache/beam/sdk/io/solace/SolaceIOTest.java | 597 +++++++++
.../beam/sdk/io/solace/data/SolaceDataUtils.java | 708 +++++++++++
.../anomaly_detection_pipeline/setup.py | 2 +-
.../transforms/aggregation/approximatequantiles.py | 4 +-
.../transforms/aggregation/approximateunique.py | 2 +-
sdks/python/apache_beam/io/fileio.py | 8 +
sdks/python/apache_beam/io/gcp/bigquery.py | 3 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 55 +-
sdks/python/apache_beam/io/gcp/gcsio_test.py | 62 +-
sdks/python/apache_beam/ml/inference/base.py | 15 +-
sdks/python/apache_beam/ml/inference/base_test.py | 39 +
.../python/apache_beam/options/pipeline_options.py | 18 +-
sdks/python/apache_beam/pipeline.py | 9 +-
sdks/python/apache_beam/pipeline_test.py | 5 +-
.../runners/dataflow/internal/apiclient.py | 4 +
sdks/python/apache_beam/yaml/pipeline.schema.yaml | 23 +-
sdks/python/apache_beam/yaml/yaml_provider.py | 51 +-
.../apache_beam/yaml/yaml_provider_unit_test.py | 80 ++
sdks/python/apache_beam/yaml/yaml_transform.py | 10 +-
sdks/typescript/package-lock.json | 32 +-
settings.gradle.kts | 5 +-
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.57.0.md | 214 ++++
website/www/site/content/en/blog/beamquest.md | 2 +-
.../blog/deploy-python-pipeline-on-flink-runner.md | 857 +++++++++++++
.../python/aggregation/approximatequantiles.md | 6 +-
.../python/aggregation/approximateunique.md | 7 +-
.../transforms/python/aggregation/batchelements.md | 5 +-
.../transforms/python/aggregation/count.md | 2 +-
.../transforms/python/aggregation/groupbykey.md | 2 +-
.../transforms/python/aggregation/tolist.md | 10 +-
.../en/documentation/transforms/python/overview.md | 2 +-
.../www/site/content/en/get-started/downloads.md | 13 +-
.../en/get-started/resources/learning-resources.md | 2 +-
website/www/site/data/authors.yml | 3 +
.../partials/section-menu/en/documentation.html | 1 +
.../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
127 files changed, 8956 insertions(+), 1611 deletions(-)
copy sdks/java/{io/csv => extensions/combiners}/build.gradle (74%)
create mode 100644
sdks/java/extensions/combiners/src/main/java/org/apache/beam/sdk/extensions/combiners/Histogram.java
copy
sdks/java/{io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempClientFactory.java
=>
extensions/combiners/src/main/java/org/apache/beam/sdk/extensions/combiners/package-info.java}
(71%)
create mode 100644
sdks/java/extensions/combiners/src/test/java/org/apache/beam/sdk/extensions/combiners/HistogramTest.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingReadableByteChannel.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingSeekableByteChannel.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingWritableByteChannel.java
copy
sdks/java/{io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempClientFactory.java
=>
extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/channels/package-info.java}
(71%)
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingChannelsIsOpenCloseMethodsTest.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingChannelsReadMethodsTest.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingChannelsWriteMethodsTest.java
create mode 100644
sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/util/channels/CountingSeekableByteChannelTest.java
create mode 100644
sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIOParseError.java
create mode 100644
sdks/java/io/csv/src/test/java/org/apache/beam/sdk/io/csv/CsvIOParseErrorTest.java
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/build.gradle
delete mode 100755
sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/contrib/create_elk_container.sh
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/resources/clientkeystore
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/build.gradle
delete mode 100755
sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/contrib/create_elk_container.sh
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOIT.java
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java
delete mode 100644
sdks/java/io/elasticsearch-tests/elasticsearch-tests-6/src/test/resources/clientkeystore
rename sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/{test
=> main}/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOITCommon.java
(99%)
rename sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/{test
=>
main}/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTestCommon.java
(99%)
rename sdks/java/io/elasticsearch-tests/elasticsearch-tests-common/src/{test
=>
main}/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTestUtils.java
(99%)
copy
sdks/java/io/{solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempClientFactory.java
=>
elasticsearch-tests/elasticsearch-tests-common/src/main/java/org/apache/beam/sdk/io/elasticsearch/package-info.java}
(71%)
create mode 100644
sdks/java/io/rabbitmq/src/test/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqMessageTest.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/main/java/org/apache/beam/sdk/io/solace/broker/MessageReceiver.java
create mode 100644
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempClient.java
create mode 100644
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SessionService.java
create mode 100644
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/SolaceCheckpointMark.java
create mode 100644
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceReader.java
create mode 100644
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceSource.java
copy
sdks/java/io/solace/src/{main/java/org/apache/beam/sdk/io/solace/broker/SessionServiceFactory.java
=> test/java/org/apache/beam/sdk/io/solace/MockEmptySessionService.java} (51%)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/MockSempClient.java
copy
sdks/java/io/solace/src/{main/java/org/apache/beam/sdk/io/solace/broker/SessionServiceFactory.java
=> test/java/org/apache/beam/sdk/io/solace/MockSempClientFactory.java} (59%)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/MockSessionService.java
copy
sdks/java/io/solace/src/{main/java/org/apache/beam/sdk/io/solace/broker/SessionServiceFactory.java
=> test/java/org/apache/beam/sdk/io/solace/MockSessionServiceFactory.java}
(57%)
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/RetryCallableManagerTest.java
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/SolaceIOTest.java
create mode 100644
sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/data/SolaceDataUtils.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
