You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2022/04/12 05:26:09 UTC
[beam] branch nightly-refs/heads/master updated (5603bd310a6 -> 2e0f79ef2b9)
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 5603bd310a6 Merge pull request #16928: [BEAM-11971] Re add reverted timer consistency PR
add ac3d6f84761 [BEAM-13898] Add tests to the pubsubx package. (#17324)
add 5773ac4b7b3 [BEAM-14285] Clean up Staticcheck Warnings in io packages (#17336)
add 0b16c103477 [BEAM-14187] Fix concurrency issue in IsmReaderImpl (#17201)
add 3e6bfa20b50 [BEAM-13151] Support multiple layers of AutoValue nesting
add fa1c6afb1ec Merge pull request #17326: [BEAM-13151] Support multiple layers of AutoValue nesting
add 41e23e68abe [BEAM-14288] Skip flaking test `test_pformat_namedtuple_with_unnamed_fields` (#17339)
add d2fe48e8c14 Simplify specifying additional dependencies in Go SDK in XLang IOs (#17216)
add 33c514b1cf2 [BEAM-14240] Clean staticcheck warnings in runner packages (#17340)
add c432cead464 [BEAM-14215] Improve argument validation in SnowflakeIO
add 977189bdf08 Merge pull request #17223 from [BEAM-14215] Improve argument validation in SnowflakeIO
add 61af8f42a9d [BEAM-14233] Merge requirements from expanded response for Java External transform
add 2452e2eccc3 Merge pull request #17248 from ihji/BEAM-14233
add 19281d6617d [BEAM-14013] Add PreCommit Kotlin examples Jenkins Job
add d9f3af0d45f [BEAM-14013] Add spark, direct, flink runners as triggers for Kotlin preCommit
add 49d530e739b Merge pull request #17312 from benWize/BEAM-14013
add 5439a91590f [BEAM-13538] Workaround to fix go-licenses crash.
add 2e0f79ef2b9 Merge pull request #17343: [BEAM-13538][BEAM-14296] Workaround to fix go-licenses crash.
No new revisions were added by this update.
Summary of changes:
...groovy => job_PreCommit_Kotlin_Examples.groovy} | 13 +-
release/go-licenses/Dockerfile | 2 +-
.../beam/runners/core/construction/External.java | 38 +++-
.../core/construction/ExternalTranslation.java | 6 +
.../core/construction/ExternalTranslationTest.java | 105 ++++++++++
.../runners/dataflow/worker/IsmReaderImpl.java | 181 ++++++++++++-----
sdks/go.mod | 3 +-
sdks/go.sum | 4 -
sdks/go/pkg/beam/core/runtime/xlangx/expand.go | 19 +-
.../core/runtime/xlangx/expansionx/download.go | 221 +++++++++++++++++++++
sdks/go/pkg/beam/core/runtime/xlangx/registry.go | 32 ++-
sdks/go/pkg/beam/io/avroio/avroio_test.go | 14 +-
sdks/go/pkg/beam/io/databaseio/util_test.go | 2 -
sdks/go/pkg/beam/io/filesystem/util_test.go | 8 +-
.../beam/io/rtrackers/offsetrange/offsetrange.go | 2 +-
sdks/go/pkg/beam/io/synthetic/source.go | 2 +-
sdks/go/pkg/beam/io/synthetic/step.go | 5 +-
sdks/go/pkg/beam/io/textio/textio_test.go | 3 +-
sdks/go/pkg/beam/io/xlang/jdbcio/jdbc.go | 26 ++-
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 12 +-
.../beam/runners/dataflow/dataflowlib/messages.go | 2 +
.../beam/runners/dataflow/dataflowlib/translate.go | 7 +-
sdks/go/pkg/beam/runners/session/session.go | 3 +
.../runners/vet/testpipeline/staticcheck.conf} | 5 +-
sdks/go/pkg/beam/util/pubsubx/pubsub.go | 11 +-
sdks/go/pkg/beam/util/pubsubx/pubsub_test.go | 187 +++++++++++++++++
sdks/go/test/integration/io/xlang/jdbc/jdbc.go | 7 +-
.../go/test/integration/io/xlang/jdbc/jdbc_test.go | 14 +-
.../beam/sdk/schemas/utils/AutoValueUtils.java | 43 +++-
.../beam/sdk/schemas/utils/ByteBuddyUtils.java | 4 +
.../beam/sdk/schemas/AutoValueSchemaTest.java | 183 +++++++++++++++++
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 49 +++--
.../test/unit/DataSourceConfigurationTest.java | 141 +++++++++++--
.../test/unit/read/SnowflakeIOReadTest.java | 52 +++++
.../runners/interactive/sql/utils_test.py | 1 +
35 files changed, 1236 insertions(+), 171 deletions(-)
copy .test-infra/jenkins/{job_PreCommit_Spotless.groovy => job_PreCommit_Kotlin_Examples.groovy} (82%)
create mode 100644 runners/core-construction-java/src/test/java/org/apache/beam/runners/core/construction/ExternalTranslationTest.java
copy sdks/{python/.coveragerc => go/pkg/beam/runners/vet/testpipeline/staticcheck.conf} (96%)
create mode 100644 sdks/go/pkg/beam/util/pubsubx/pubsub_test.go