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 51e0e4e [BEAM-13605] Modify groupby.apply implementation in
preparation for pandas 1.4.0 (#16706)
add 9794fb4 Merge pull request #16436 from [BEAM-1330] - DatastoreIO
Writes should flush early when duplicate keys arrive
add 32a0f09 [BEAM-13757] adds pane observation in DoFn (#16629)
add 8ea77f9 Fix timer consistency in direct runner
add 6814a06 Merge pull request #16650:[BEAM-11971] Fix directrunner timer
consistency
add 5beae2a [BEAM-13605] Add support for pandas 1.4.0 (#16590)
add 99b903f Change links to Books from Amazon to Publisher
add 9434c4d Merge pull request #16718: [website] Change links to Books
from Amazon to Publisher
add b26988c [BEAM-13761] adds Debezium IO wrapper for Go SDK (#16642)
add 5c5a06f Allow Java 17 to be used in SDK
add 02d442d add testing support
add 3f5ab6a Add more testing support for java 17
add 65e6437 workaround for jamm
add f396331 Add Jenkins test for Java 17
add e0be225 Fix jvm hex and skip errorprone
add dbd9b2c Fix display data for anonymous classes
add 4344afb fix jpms tests
add c1ff03b skip zetasql
add 6c54ae0 Merge branch 'master' of github.com:apache/beam into
java7tests
add 0422e20 spotless
add 28280ee spotless
add 88365f6 Merge branch 'master' of github.com:apache/beam into
java7tests
add bda7732 Fix trigger
add 5b3b3d0 skip checker framework
add 74557c5 fix app name
add a847c1c remove duplicate property check
add 940d4f3 Merge branch 'master' of github.com:apache/beam into
java7tests
add 07aa907 Merge pull request #16640 from kileys/java7tests
add 8da6363 [BEAM-13024] Unify PipelineOptions behavior (#16719)
No new revisions were added by this update.
Summary of changes:
.../job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy | 246 ++++++++++++++++
.../job_LoadTests_GBK_Dataflow_V2_Java17.groovy | 311 +++++++++++++++++++++
.../job_LoadTests_ParDo_Dataflow_V2_Java17.groovy | 217 ++++++++++++++
...PostCommit_Java_Dataflow_Examples_Java17.groovy | 46 +++
...tCommit_Java_Examples_Dataflow_V2_Java17.groovy | 50 ++++
...job_PostCommit_Java_Jpms_Dataflow_Java17.groovy | 51 ++++
.../job_PostCommit_Java_Jpms_Direct_Java17.groovy | 51 ++++
...stCommit_Java_Nexmark_Dataflow_V2_Java17.groovy | 67 +++++
...mit_Java_ValidatesRunner_Dataflow_Java17.groovy | 57 ++++
...ommit_Java_ValidatesRunner_Direct_Java17.groovy | 55 ++++
.../jenkins/job_PreCommit_SQL_Java17.groovy | 55 ++++
..._Precommit_Java_Examples_Dataflow_Java17.groovy | 56 ++++
CHANGES.md | 18 ++
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 50 +++-
.../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 +++---
.../beam/runners/direct/WatermarkManager.java | 250 +++++++----------
.../apache/beam/runners/local/ExecutionDriver.java | 2 +-
sdks/go.sum | 2 +
sdks/go/pkg/beam/core/funcx/fn.go | 39 ++-
sdks/go/pkg/beam/core/funcx/fn_test.go | 104 ++++++-
sdks/go/pkg/beam/core/runtime/exec/decode.go | 2 +-
sdks/go/pkg/beam/core/runtime/exec/fn.go | 48 ++--
sdks/go/pkg/beam/core/runtime/exec/fn_arity.go | 122 ++++----
sdks/go/pkg/beam/core/runtime/exec/fn_arity.tmpl | 14 +-
sdks/go/pkg/beam/core/runtime/exec/fn_test.go | 6 +-
sdks/go/pkg/beam/core/runtime/exec/pardo.go | 16 +-
sdks/go/pkg/beam/core/runtime/options.go | 18 ++
sdks/go/pkg/beam/core/runtime/options_test.go | 33 ++-
sdks/go/pkg/beam/io/xlang/debeziumio/debezium.go | 138 +++++++++
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 8 +-
sdks/go/pkg/beam/runners/direct/direct.go | 1 +
.../go/pkg/beam/runners/universal/runnerlib/job.go | 1 +
sdks/go/test/integration/integration.go | 19 +-
.../test/integration/io/xlang/debezium/debezium.go | 35 +++
.../integration/io/xlang/debezium/debezium_test.go | 93 ++++++
sdks/go/test/integration/primitives/pardo.go | 25 ++
sdks/go/test/integration/primitives/pardo_test.go | 5 +
.../go/test/integration/primitives/window_panes.go | 51 ++++
.../{pardo_test.go => window_panes_test.go} | 22 +-
.../beam/sdk/transforms/display/DisplayData.java | 9 +-
.../org/apache/beam/sdk/transforms/ParDoTest.java | 10 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 13 +-
.../beam/sdk/io/gcp/datastore/V1WriteIT.java | 92 +++++-
sdks/java/testing/jpms-tests/build.gradle | 30 +-
.../org/apache/beam/sdk/jpmstests/WordCount.java | 8 +
.../testutils/jvmverification/JvmVerification.java | 2 +-
sdks/python/apache_beam/dataframe/frames.py | 27 +-
sdks/python/apache_beam/dataframe/io_test.py | 8 +
.../apache_beam/dataframe/pandas_doctests_test.py | 34 ++-
sdks/python/setup.py | 2 +-
sdks/python/test-suites/tox/py38/build.gradle | 4 +
sdks/python/tox.ini | 3 +-
.../documentation/resources/learning-resources.md | 4 +-
57 files changed, 2434 insertions(+), 448 deletions(-)
create mode 100644
.test-infra/jenkins/job_LoadTests_CoGBK_Dataflow_V2_Java17.groovy
create mode 100644
.test-infra/jenkins/job_LoadTests_GBK_Dataflow_V2_Java17.groovy
create mode 100644
.test-infra/jenkins/job_LoadTests_ParDo_Dataflow_V2_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_Dataflow_Examples_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_Examples_Dataflow_V2_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_Jpms_Dataflow_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_Jpms_Direct_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_Nexmark_Dataflow_V2_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_ValidatesRunner_Dataflow_Java17.groovy
create mode 100644
.test-infra/jenkins/job_PostCommit_Java_ValidatesRunner_Direct_Java17.groovy
create mode 100644 .test-infra/jenkins/job_PreCommit_SQL_Java17.groovy
create mode 100644
.test-infra/jenkins/job_Precommit_Java_Examples_Dataflow_Java17.groovy
create mode 100644 sdks/go/pkg/beam/io/xlang/debeziumio/debezium.go
create mode 100644 sdks/go/test/integration/io/xlang/debezium/debezium.go
create mode 100644 sdks/go/test/integration/io/xlang/debezium/debezium_test.go
create mode 100644 sdks/go/test/integration/primitives/window_panes.go
copy sdks/go/test/integration/primitives/{pardo_test.go =>
window_panes_test.go} (68%)
