[beam] tag nightly-master updated (1466db9 -> 0350f2e)

[gi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from 1466db9  (commit)
      to 0350f2e  (commit)
    from 1466db9  Merge pull request #13309 from ibzib/fngroup
     add 243e5df  [BEAM-11391] Improve Nexmark Kafka support to track watermarks using commit time, allow specifying the number of partitions instead of requiring launcher to have access to kafka cluster, and removing unneeded deserialization of keys.
     add bfdb3e5  Merge pull request #13472: [BEAM-11391] Improve Nexmark Kafka support to track
     add 164a7b6  [BEAM-9426] Add JVM properties to JavaJarJobServer. (#13581)
     add e9fa621  Release bundle processor when any exceptions during processing.
     add 060b083  Merge pull request #13568 from [BEAM-3245] Release bundle processor when any exceptions during processing.
     add b1fcfe9  [BEAM-10925] Add UdfProvider interface.
     add e4ee5f5  Merge pull request #13587 from ibzib/udf-provider
     add c679de6  [BEAM-9637] Add all runners to Python --runner help text.
     add 0350f2e  Merge pull request #13584 from ibzib/BEAM-9637

No new revisions were added by this update.

Summary of changes:
 .../beam/sdk/extensions/sql/udf/UdfProvider.java}  | 28 +++----
 .../fn/harness/control/ProcessBundleHandler.java   | 87 ++++++++++++----------
 .../apache/beam/sdk/nexmark/NexmarkLauncher.java   | 38 +++++++---
 .../apache/beam/sdk/nexmark/NexmarkOptions.java    | 14 ++++
 .../python/apache_beam/options/pipeline_options.py | 29 +++++++-
 .../apache_beam/runners/portability/job_server.py  | 10 ++-
 .../runners/portability/job_server_test.py         | 84 +++++++++++++++++++++
 sdks/python/apache_beam/runners/runner.py          | 24 ++----
 8 files changed, 224 insertions(+), 90 deletions(-)
 copy sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/InMemoryMetaTableProvider.java => udf/src/main/java/org/apache/beam/sdk/extensions/sql/udf/UdfProvider.java} (62%)
 create mode 100644 sdks/python/apache_beam/runners/portability/job_server_test.py