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
