[beam] branch master updated (952c608 -> e2bb239)
This is an automated email from the ASF dual-hosted git repository. goenka pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 952c608 [BEAM-9013] TestStream fix for DataflowRunner (#10445) add e2bb239 [BEAM-8575] Refactor test_do_fn_with_windowing_in_finish_bundle to work with Dataflow runner (#10447) No new revisions were added by this update. Summary of changes: sdks/python/apache_beam/transforms/ptransform_test.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-)
[beam] branch master updated (8d9f0a3 -> 952c608)
This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 8d9f0a3 Merge pull request #10496 [BEAM-8671] Fix Python 3.7 ParDo test job name add 952c608 [BEAM-9013] TestStream fix for DataflowRunner (#10445) No new revisions were added by this update. Summary of changes: .../runners/dataflow/dataflow_runner.py| 2 +- .../apache_beam/runners/direct/direct_runner.py| 45 +++- .../apache_beam/runners/direct/test_stream_impl.py | 173 +++ .../runners/direct/transform_evaluator.py | 4 +- sdks/python/apache_beam/testing/test_stream.py | 174 +-- .../apache_beam/testing/test_stream_it_test.py | 237 + 6 files changed, 462 insertions(+), 173 deletions(-) create mode 100644 sdks/python/apache_beam/runners/direct/test_stream_impl.py create mode 100644 sdks/python/apache_beam/testing/test_stream_it_test.py
[beam] branch master updated (0028b79 -> 8d9f0a3)
This is an automated email from the ASF dual-hosted git repository. tvalentyn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 0028b79 Merge pull request #10404 [BEAM-8977] Resolve test flakiness add 2b17bef [BEAM-8671] Fix Python 3.7 ParDo test job name add 8d9f0a3 Merge pull request #10496 [BEAM-8671] Fix Python 3.7 ParDo test job name No new revisions were added by this update. Summary of changes: .test-infra/jenkins/job_LoadTests_ParDo_Python_37.groovy | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[beam] branch master updated (16757ef -> 0028b79)
This is an automated email from the ASF dual-hosted git repository. tvalentyn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 16757ef [BEAM-8335] On Unbounded Source change (#10442) add 2375217 [BEAM-8977] Resolve test flakiness add 0028b79 Merge pull request #10404 [BEAM-8977] Resolve test flakiness No new revisions were added by this update. Summary of changes: .../display/pcoll_visualization_test.py| 70 ++ 1 file changed, 31 insertions(+), 39 deletions(-)
[beam] branch master updated (9bceff5 -> 16757ef)
This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 9bceff5 Merge pull request #10403 from ibzib/spark-jar add 16757ef [BEAM-8335] On Unbounded Source change (#10442) No new revisions were added by this update. Summary of changes: .../runners/interactive/background_caching_job.py | 54 +++- .../interactive/background_caching_job_test.py | 144 + .../interactive/display/pipeline_graph_test.py | 12 +- .../runners/interactive/interactive_environment.py | 7 + .../runners/interactive/testing/mock_ipython.py| 24 ++-- 5 files changed, 221 insertions(+), 20 deletions(-)
[beam] branch master updated (0851849 -> 9bceff5)
This is an automated email from the ASF dual-hosted git repository. ibzib pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 0851849 [BEAM-5605] Ensure that split calls are routed to the active bundle processor for the bundle id. (#10489) new bf6577e Import freezegun for Python time testing. new b329de6 Allow message stream to yield duplicates. new 4479865 [BEAM-8891] Create and submit Spark portable jar in Python. new 6f7b2b2 Refactor shared uber jar generation code into common subclass. new 4996c14 Make Spark REST URL a separate pipeline option. new 9bceff5 Merge pull request #10403 from ibzib/spark-jar The 24863 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../beam/runners/spark/SparkPipelineRunner.java| 4 + .../python/apache_beam/options/pipeline_options.py | 22 ++ .../runners/portability/abstract_job_service.py| 78 ++- .../portability/flink_uber_jar_job_server.py | 71 +- .../runners/portability/portable_runner.py | 11 +- .../runners/portability/spark_runner.py| 30 ++- .../portability/spark_uber_jar_job_server.py | 255 + .../portability/spark_uber_jar_job_server_test.py | 209 + sdks/python/setup.py | 1 + 9 files changed, 593 insertions(+), 88 deletions(-) create mode 100644 sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py create mode 100644 sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server_test.py
[beam] branch dependabot/pip/sdks/python/container/tensorflow-1.15.0 updated (a82375b -> 0ac6601)
This is an automated email from the ASF dual-hosted git repository. altay pushed a change to branch dependabot/pip/sdks/python/container/tensorflow-1.15.0 in repository https://gitbox.apache.org/repos/asf/beam.git. from a82375b Bump tensorflow from 1.14.0 to 1.15.0 in /sdks/python/container add 0ac6601 Update tensorflow to latest version 2.1.0 No new revisions were added by this update. Summary of changes: sdks/python/container/base_image_requirements.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
