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 9524b56c148 Add observability (#37716)
add 30518c840bf [Stateful] Implement length-aware keying to minimize
padding in BatchElements (Part 2/3) (#37565)
add 5bee123ce8e Add monitoring for model manager (#37703)
add 4b3dcf26142 Fix GroupBy snippet tests for issue #30778 (#37672)
add 342de16b2f2 Fix Python PostCommit Flink runner log spam switching to
simple logger (#37720)
add af81a0c1635 Fix ml_base dependency (#37721)
add 5a6f763da54 [Drain] OnTimer - propagate caused by drain bit up to
DoFnRunner (#37012)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 10 +-
.../org/apache/beam/runners/core/DoFnRunner.java | 4 +-
.../runners/core/LateDataDroppingDoFnRunner.java | 7 +-
...TimeBoundedSplittableProcessElementInvoker.java | 6 +
.../apache/beam/runners/core/ProcessFnRunner.java | 4 +-
.../runners/core/PushbackSideInputDoFnRunner.java | 4 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 25 ++-
.../core/SimplePushbackSideInputDoFnRunner.java | 7 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 2 +-
.../beam/runners/core/StatefulDoFnRunner.java | 16 +-
.../beam/runners/core/SimpleDoFnRunnerTest.java | 17 +-
.../SimplePushbackSideInputDoFnRunnerTest.java | 20 +-
.../beam/runners/core/StatefulDoFnRunnerTest.java | 3 +-
.../apache/beam/runners/direct/ParDoEvaluator.java | 3 +-
.../wrappers/streaming/DoFnOperator.java | 3 +-
.../functions/FlinkStatefulDoFnFunction.java | 3 +-
.../wrappers/streaming/DoFnOperator.java | 3 +-
.../flink/metrics/DoFnRunnerWithMetricsUpdate.java | 14 +-
.../functions/FlinkStatefulDoFnFunction.java | 3 +-
.../wrappers/streaming/DoFnOperator.java | 12 +-
.../streaming/ExecutableStageDoFnOperator.java | 7 +-
.../streaming/stableinput/BufferedElements.java | 10 +-
.../streaming/stableinput/BufferingDoFnRunner.java | 4 +-
.../wrappers/streaming/DoFnOperatorTest.java | 4 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 13 +-
.../dataflow/worker/DataflowProcessFnRunner.java | 4 +-
.../dataflow/worker/GroupAlsoByWindowFnRunner.java | 4 +-
.../runners/dataflow/worker/SimpleParDoFn.java | 3 +-
.../StreamingKeyedWorkItemSideInputDoFnRunner.java | 4 +-
.../worker/StreamingSideInputDoFnRunner.java | 4 +-
.../fnexecution/control/TimerReceiverFactory.java | 3 +-
.../translation/PipelineTranslatorUtils.java | 3 +-
.../fnexecution/control/RemoteExecutionTest.java | 4 +-
.../runners/fnexecution/wire/CommonCoderTest.java | 4 +-
.../runners/jet/processors/StatefulParDoP.java | 3 +-
.../samza/metrics/DoFnRunnerWithMetrics.java | 13 +-
.../runners/samza/runtime/AsyncDoFnRunner.java | 7 +-
.../apache/beam/runners/samza/runtime/DoFnOp.java | 3 +-
.../runtime/DoFnRunnerWithKeyedInternals.java | 13 +-
.../beam/runners/samza/runtime/PortableDoFnOp.java | 3 +-
.../runners/samza/runtime/SamzaDoFnRunners.java | 7 +-
.../translation/batch/DoFnRunnerFactory.java | 4 +-
.../translation/batch/DoFnRunnerWithMetrics.java | 14 +-
.../spark/translation/AbstractInOutIterator.java | 3 +-
.../spark/translation/DoFnRunnerWithMetrics.java | 14 +-
.../translation/AbstractInOutIteratorTest.java | 9 +-
.../translation/SparkInputDataProcessorTest.java | 4 +-
.../java/org/apache/beam/sdk/transforms/DoFn.java | 7 +
.../org/apache/beam/sdk/transforms/DoFnTester.java | 6 +
.../construction/SplittableParDoNaiveBounded.java | 6 +
.../apache/beam/sdk/util/construction/Timer.java | 29 ++-
.../beam/sdk/util/construction/TimerTest.java | 28 ++-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 29 ++-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 4 +-
...plittablePairWithRestrictionDoFnRunnerTest.java | 4 +-
.../harness/control/ProcessBundleHandlerTest.java | 13 +-
.../transforms/aggregation/groupby_attr.py | 13 +-
.../transforms/aggregation/groupby_attr_expr.py | 10 +-
.../transforms/aggregation/groupby_expr.py | 5 +-
.../aggregation/groupby_expr_aggregate.py | 10 +-
.../aggregation/groupby_global_aggregate.py | 6 +-
.../aggregation/groupby_simple_aggregate.py | 5 +-
.../transforms/aggregation/groupby_test.py | 20 +-
.../transforms/aggregation/groupby_two_exprs.py | 9 +-
sdks/python/apache_beam/metrics/metric.py | 30 ++-
sdks/python/apache_beam/ml/inference/base.py | 17 ++
sdks/python/apache_beam/ml/inference/base_test.py | 39 ++++
.../apache_beam/ml/inference/model_manager.py | 28 +++
.../apache_beam/ml/inference/model_manager_test.py | 65 ++++++
sdks/python/apache_beam/transforms/util.py | 60 +++++-
sdks/python/apache_beam/transforms/util_test.py | 233 +++++++++++++++++++++
sdks/python/setup.py | 24 ++-
sdks/python/test-suites/portable/common.gradle | 37 ++--
73 files changed, 890 insertions(+), 181 deletions(-)
