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 64a92d73895 Merge pull request #17325: [BEAM-14263] Disable
BigQueryIOStorageWriteIT for Runner v2 test suite
add 867a5859c4b Re-raise exceptions swallowed in several Python I/O
connectors
add f5a9712ef94 Merge pull request #17329 from
chamikaramj/re_raise_swallowed_exceptions
add 5603bd310a6 Merge pull request #16928: [BEAM-11971] Re add reverted
timer consistency PR
No new revisions were added by this update.
Summary of changes:
.../apache/beam/runners/core/TimerInternals.java | 17 +-
.../beam/runners/direct/DirectTimerInternals.java | 72 +++---
.../direct/ExecutorServiceParallelExecutor.java | 2 +-
.../beam/runners/direct/QuiescenceDriver.java | 78 ++++---
.../direct/StatefulParDoEvaluatorFactory.java | 83 +++----
.../runners/direct/TestStreamEvaluatorFactory.java | 13 +-
.../beam/runners/direct/WatermarkManager.java | 255 +++++++++------------
.../apache/beam/runners/local/ExecutionDriver.java | 2 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 39 +++-
.../io/gcp/datastore/v1new/datastoreio.py | 2 +
.../io/gcp/datastore/v1new/datastoreio_test.py | 18 +-
sdks/python/apache_beam/io/gcp/gcsio.py | 1 +
sdks/python/apache_beam/io/gcp/gcsio_test.py | 46 +++-
13 files changed, 319 insertions(+), 309 deletions(-)
