[beam] branch nightly-refs/heads/master updated (9317462f73c -> e596abf7660)

[gi...@apache.org]

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 9317462f73c [BEAM-13829] Expose status API from Go SDK Harness (#16957)
     add 3f601400fc8 Avoid pr-bot state desync (#17299)
     add 2a8a1ac0f2d [BEAM-14259] Clean up staticcheck warnings in the exec package (#17285)
     add 862f236c4ee Minor: Prefer registered schema in SQL docs (#17298)
     add 8a71bcbf82a [Playground] add meta tags (#17207)
     add 372978533e7 fixes golint and deprecated issues in recent Go SDK import (#17304)
     add 96f775fe4d1 [BEAM-14262] Update plugins for Dockerized Jenkins.
     add f1c4003301a Add ansicolor and ws-cleanup plugins.
     add 48bdce3d764 Merge pull request #17303 from ibzib/update-plugins
     add f90379a67f9 [BEAM-14266] Replace deprecated ptypes package uses (#17302)
     add a2391149eae [BEAM-11936] Fix rawtypes warnings in SnowflakeIO (#17257)
     add e596abf7660 Merge pull request #17262: [BEAM-14244] Use the supplied output timestamp for processing time timers rather than the input watermark

No new revisions were added by this update.

Summary of changes:
 .test-infra/dockerized-jenkins/plugins.txt         | 121 +++++++--------
 playground/frontend/web/index.html                 |  10 +-
 .../apache/beam/runners/core/SimpleDoFnRunner.java |  60 +++-----
 .../wrappers/streaming/DoFnOperator.java           |  15 +-
 scripts/ci/pr-bot/processNewPrs.ts                 |   2 +
 scripts/ci/pr-bot/shared/persistentState.ts        |   9 +-
 sdks/go/pkg/beam/core/graph/coder/coder.go         |   2 +
 sdks/go/pkg/beam/core/runtime/exec/coder.go        |   4 +-
 sdks/go/pkg/beam/core/runtime/exec/datasource.go   |   2 +-
 .../go/pkg/beam/core/runtime/exec/dynsplit_test.go |  16 +-
 sdks/go/pkg/beam/core/runtime/exec/fn_test.go      |   6 +-
 .../pkg/beam/core/runtime/exec/fullvalue_test.go   |   6 -
 sdks/go/pkg/beam/core/runtime/exec/pardo.go        |   2 +-
 sdks/go/pkg/beam/core/runtime/exec/pardo_test.go   |   4 -
 sdks/go/pkg/beam/core/runtime/graphx/translate.go  |  10 +-
 sdks/go/pkg/beam/core/runtime/harness/logging.go   |   4 +-
 .../pkg/beam/core/runtime/harness/worker_status.go |   1 +
 .../core/runtime/harness/worker_status_test.go     |   4 +-
 sdks/go/pkg/beam/core/typex/special.go             |   2 +-
 .../apache/beam/sdk/io/snowflake/SnowflakeIO.java  | 167 ++++++++++-----------
 .../crosslanguage/SnowflakeTransformRegistrar.java |   1 +
 .../io/snowflake/crosslanguage/WriteBuilder.java   |  10 +-
 .../io/snowflake/data/SnowflakeTableSchema.java    |   3 +-
 .../services/SnowflakeBatchServiceConfig.java      |   2 +-
 .../services/SnowflakeBatchServiceImpl.java        |  15 +-
 .../{ServiceConfig.java => SnowflakeServices.java} |  25 ++-
 ...lakeService.java => SnowflakeServicesImpl.java} |  15 +-
 .../services/SnowflakeStreamingServiceConfig.java  |   2 +-
 .../services/SnowflakeStreamingServiceImpl.java    |   5 +-
 .../test/FakeSnowflakeBatchServiceImpl.java        |   5 +-
 ...Manager.java => FakeSnowflakeServicesImpl.java} |  19 +--
 .../test/FakeSnowflakeStreamingServiceImpl.java    |   7 +-
 .../beam/sdk/io/snowflake/test/TestUtils.java      |  34 ++---
 .../test/unit/data/SnowflakeDataTypeValidTest.java |   5 +-
 .../test/unit/read/SnowflakeIOReadTest.java        |  46 +++---
 .../test/unit/write/CreateDispositionTest.java     |  21 ++-
 .../unit/write/QueryDispositionLocationTest.java   |  17 +--
 .../test/unit/write/SchemaDispositionTest.java     |  17 +--
 .../test/unit/write/SnowflakeIOWriteTest.java      |  23 ++-
 .../test/unit/write/StreamingWriteTest.java        |  19 +--
 .../en/documentation/dsls/sql/walkthrough.md       |  17 +--
 41 files changed, 351 insertions(+), 404 deletions(-)
 rename sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/{ServiceConfig.java => SnowflakeServices.java} (58%)
 rename sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/{SnowflakeService.java => SnowflakeServicesImpl.java} (75%)
 copy sdks/java/io/snowflake/src/test/java/org/apache/beam/sdk/io/snowflake/test/{FakeSnowflakeIngestManager.java => FakeSnowflakeServicesImpl.java} (70%)