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 2021/01/28 04:50:01 UTC
[beam] tag nightly-master updated (3d7c3a7 -> d289168)
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 3d7c3a7 (commit)
to d289168 (commit)
from 3d7c3a7 Merge pull request #13813 from ibzib/BEAM-11689
add ed5b117 [BEAM-10961] Enable strict dependency checking on sdks/java/io/hadoop-format (#13799)
add fc14f0b [BEAM-11695] Remove translations.pack_combiners from default optimizers for FnApiRunner and PortableRunner (#13816)
add cb4c2de [BEAM-11697] Upgrade Flink runner to Flink versions 1.12.1 and 1.11.3
add 4edb26f Merge pull request #13818 from iemejia/BEAM-11697-update-flink-versions
add 1b6c8e3 Enabled strict dependency on flink runner
add 0144bdb Added new line
add e7dacc2 removed checker-qual
add 75bc373 Removed flink-clients dep
add 02e3666 set enableStrictDependencies:true
add 5d83602 made flink-clients runtimeOnly
add 248e990 Remove stray colon.
add 280107a Merge pull request #13658 from sonam-vend/flink-runner
add fc17382 Moving to 2.29.0-SNAPSHOT on master branch.
add a4e230b [BEAM-11531] Add pd.to_datetime, handle DeferredBase args in _defer_to_pandas (#13706)
add 2975487 [BEAM-8725] bump snappy-java to 1.1.8.4
add f62887e Merge pull request #13820: [BEAM-8726] bump snappy-java to 1.1.8.4
add b0c8529 strict dependency checking on sdks/io/amazon-web-services*
add 9c749fe move amazon-web-services* changes to another PR
add a176ac9 undo previous erroneous commit
add 3824542 better use of variables
add 944365a Merge pull request #13793: [BEAM-10961] strict dependency checking on sdks/io/amazon-web-services*
add 870cc22 [BEAM-11689] Add public.nexus.pentaho.org to offline repositories.
add aab90f2 Merge pull request #13823 from ibzib/pentaho-offline
add 3b51aaa [BEAM-11695] Combiner packing in Dataflow (#13763)
add be2a2cf [BEAM-11165] Async ZetaSQL Calc
add 2cc0f8f Merge pull request #13759: [BEAM-11165] Async ZetaSQL Calc
add 8070497 Add BigDecimal support for SpannerIO
add 9a4505e Merge pull request #13762: [BEAM-11643] Add BigDecimal support for SpannerIO
add a9d8612 [BEAM-11679] Override PubsubUnboundedSource transform for dataflow runner v2
add 56cebda Populate PubsubMessage message id
add 02ec09c Enable tests
add 197d338 Exclude failing FhirIO ITs
add bc7930e Include runner v2 IT tests in java post commit
add ebc3bc3 Merge pull request #13797 from [BEAM-11679] Override PubsubUnboundedSource transform for dataflow runner v2
add 0b85362 [BEAM-11699] Correct python environment directly for fnApiJobServerSetup
add d289168 Merge pull request #13822 from y1chi/BEAM-11699
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 4 +-
.../org/apache/beam/gradle/Repositories.groovy | 1 +
gradle.properties | 4 +-
runners/flink/1.10/job-server/build.gradle | 4 +
runners/flink/1.11/build.gradle | 2 +-
runners/flink/1.11/job-server/build.gradle | 4 +
runners/flink/1.12/build.gradle | 2 +-
runners/flink/1.12/job-server/build.gradle | 4 +
runners/flink/1.8/job-server/build.gradle | 4 +
runners/flink/1.9/job-server/build.gradle | 4 +
runners/flink/flink_runner.gradle | 12 +-
runners/google-cloud-dataflow-java/build.gradle | 13 +-
.../beam/runners/dataflow/DataflowRunner.java | 207 ++++++++++++++++-----
.../beam/runners/dataflow/TestDataflowRunner.java | 6 +-
sdks/go/pkg/beam/core/core.go | 2 +-
.../beam/sdk/testing/TestPipelineOptions.java | 10 +
.../extensions/sql/zetasql/BeamZetaSqlCalcRel.java | 116 ++++++++++--
sdks/java/io/amazon-web-services/build.gradle | 4 +-
sdks/java/io/amazon-web-services2/build.gradle | 11 +-
.../beam/sdk/io/gcp/pubsub/PubsubMessages.java | 7 +-
.../sdk/io/gcp/spanner/MutationSizeEstimator.java | 23 +++
.../beam/sdk/io/gcp/pubsub/PubsubReadIT.java | 6 +-
.../io/gcp/spanner/MutationSizeEstimatorTest.java | 25 +++
sdks/java/io/hadoop-format/build.gradle | 5 +-
.../apache_beam/dataframe/pandas_doctests_test.py | 1 -
.../dataframe/pandas_top_level_functions.py | 35 +++-
.../runners/dataflow/dataflow_runner.py | 87 ++++++---
.../runners/dataflow/dataflow_runner_test.py | 33 ++++
.../runners/dataflow/ptransform_overrides.py | 27 +++
.../runners/portability/fn_api_runner/fn_runner.py | 1 -
.../portability/fn_api_runner/fn_runner_test.py | 52 ++++++
.../portability/fn_api_runner/translations.py | 3 +-
.../runners/portability/portable_runner.py | 1 -
sdks/python/apache_beam/version.py | 2 +-
sdks/python/test-suites/direct/xlang/build.gradle | 4 +-
36 files changed, 591 insertions(+), 136 deletions(-)