This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 194fe17 (commit)
to 5ddb69f (commit)
from 194fe17 [BEAM-12062] Python-Katas Doc Fixes and Lesson Enhancements
(#14353)
add 2097ac8 Removes Java environment de-duping
add 7963cd3 Merge pull request #14385: [BEAM-11935] Removes Java
environment de-duping
add a49b4d8 [BEAM-12069] Remove mock from base_image_requirements.txt
(#14389)
add efaea05 [BEAM-5537] Allow google-cloud-bigquery 2.x (#14391)
add 6b3077a [BEAM-12081] Fix AwsOptions Jackson (de)serialization of
integer values
add 83ccda1 Merge pull request #14400: [BEAM-12081] Fix AwsOptions
Jackson (de)serialization of integer values
add 7254855 Merge pull request #14274 from [BEAM-9547] Initial
implementation for where, mask
add 2354edd Update V1Beta3 API and add DebugOptions
add b43952c Merge pull request #14380 from [BEAM-10994] Java: Update
V1Beta3 API and add DebugOptions
add c2baacd Update dev Dataflow containers to latest version.
add 5474e0a Merge pull request #14402: Update dev Dataflow containers to
latest version.
add 37a1b12 fix: variables names in test-stream.md
add 6fc8bbc Merge pull request #14399 from NicholasAzar/patch-1
add b26f1ac Update Dataflow V1Beta3 to newest version to add the
Environment.DebugOptions
add 0f43969 Add the 'enable_hot_key_logging' PipelineOption and plumb it
to the Dataflow Environment.DebugOptions proto.
add 2b1a63d Merge pull request #14381 from [BEAM-10994] Python: Update
V1Beta3 API and add DebugOptions
add cf3f2a4 Merge pull request #14372 from [BEAM-12014] Add BIGNUMERIC
support in BEAM
add 3434af0 [BEAM-12033] Create ZetaSqlException, which contains a GRPC
Status code.
add a370df2 Merge pull request #14393 from ibzib/out-of-range
add c33a1ca [BEAM-12079] Deterministic coding enforcement causes
_StreamToBigQuery/CommitInsertIds/GroupByKey to fail
add 5ddb69f Merge pull request #14396 from [BEAM-12079] Fix
_StreamToBigQuery/CommitInsertIds/GroupByKey failure
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../dataflow/DataflowPipelineTranslator.java | 6 ++
.../dataflow/DataflowPipelineTranslatorTest.java | 22 ++++++
.../extensions/sql/zetasql/BeamZetaSqlCatalog.java | 3 +-
.../{package-info.java => ZetaSqlException.java} | 22 ++++--
.../zetasql/translation/ExpressionConverter.java | 60 ++++++++++------
.../sql/zetasql/ZetaSqlNativeUdfTest.java | 3 +-
.../sql/zetasql/ZetaSqlNumberTypesTest.java | 7 +-
sdks/java/io/amazon-web-services/build.gradle | 1 +
.../apache/beam/sdk/io/aws/options/AwsModule.java | 13 ++--
.../beam/sdk/io/aws/options/AwsModuleTest.java | 20 ++++++
.../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 2 +
.../sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java | 70 +++++++++++++------
sdks/python/apache_beam/dataframe/frames.py | 51 ++++++++++++++
sdks/python/apache_beam/dataframe/frames_test.py | 16 +++++
.../apache_beam/dataframe/pandas_doctests_test.py | 8 ++-
sdks/python/apache_beam/io/gcp/bigquery.py | 9 +--
.../python/apache_beam/options/pipeline_options.py | 7 ++
.../runners/dataflow/internal/apiclient.py | 26 +------
.../runners/dataflow/internal/apiclient_test.py | 81 ++++++----------------
.../clients/dataflow/dataflow_v1b3_messages.py | 41 +++++++----
.../apache_beam/runners/dataflow/internal/names.py | 4 +-
sdks/python/apache_beam/transforms/environments.py | 6 --
sdks/python/container/base_image_requirements.txt | 1 -
sdks/python/setup.py | 2 +-
website/www/site/content/en/blog/test-stream.md | 12 ++--
26 files changed, 316 insertions(+), 179 deletions(-)
copy
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/{package-info.java
=> ZetaSqlException.java} (62%)