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 fe9c78a7e8c fix interactive environment circular import (#37147)
add c0fe932a588 Update BOM to 26.73.0 (#37142)
add 5d658c1e867 [Dataflow Streaming] Improve logs (#37152)
add dfe01c0f092 Add WindmillTagEncoding Interface (#37150)
add 423a3c38b06 update py container tag (#37144)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 14 +--
.../worker/StreamingModeExecutionContext.java | 40 ++++---
.../dataflow/worker/WindmillKeyedWorkItem.java | 16 +--
.../dataflow/worker/WindmillTimerInternals.java | 18 +--
.../dataflow/worker/WindowingWindmillReader.java | 8 +-
.../streaming/KeyCommitTooLargeException.java | 4 +-
.../worker/windmill/state/CachingStateTable.java | 29 +++--
.../windmill/state/WindmillCombiningState.java | 4 +-
.../windmill/state/WindmillStateInternals.java | 4 +-
.../worker/windmill/state/WindmillTagEncoding.java | 131 +++++++++++++++++++++
...tateTagUtil.java => WindmillTagEncodingV1.java} | 101 ++--------------
.../processing/failures/WorkFailureProcessor.java | 22 ++--
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 12 +-
...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 9 +-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 42 +++++--
.../windmill/state/WindmillStateCacheTest.java | 16 +--
.../windmill/state/WindmillStateInternalsTest.java | 8 +-
...tilTest.java => WindmillTagEncodingV1Test.java} | 22 ++--
.../container/license_scripts/dep_urls_java.yaml | 2 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
20 files changed, 303 insertions(+), 201 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncoding.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/{WindmillStateTagUtil.java
=> WindmillTagEncodingV1.java} (73%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/state/{WindmillStateTagUtilTest.java
=> WindmillTagEncodingV1Test.java} (93%)
