[beam] tag nightly-master updated (15c89fd -> 49b9d1b)
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 15c89fd (commit) to 49b9d1b (commit) from 15c89fd Merge pull request #14221: Add example of Spark rest URL. add ee29766 Better error for missing java. add 6e799fa Merge pull request #14266 from robertwb/java-error add f561a83 Revert "Add License file for the Go SDK for pkg.go.dev" add ec64a81 Merge pull request #14267 from apache/revert-11657-lostluck-patch-2 add d6436b3 [BEAM-11979] Ignore not serializable filter fields in python MongoDBIO display data add 9791ef9 Merge pull request #14237 from [BEAM-11979] Ignore not serializable filter fields in python MongoDBI… add abc7b20 [BEAM-11992] Run CrossLanguage ValidatesRunner tests only for Spark 2 add 540957e Merge pull request #14253: [BEAM-11992] Run CrossLanguage ValidatesRunner tests only for Spark 2 add 6db22c6 [BEAM-8778] Bump software.amazon.awssdk version to 2.15.31 add c4f62ca Merge pull request #14264: [BEAM-8778] Bump software.amazon.awssdk version to 2.15.31 add 3fc2ab1 [BEAM-9547] Add NDFrame to doctests, implement a few more operations (#14236) add 9113c6f [BEAM-9283] Add Java 11 Jpms compatibility tests for Spark runner add aee24ad Merge pull request #14270: [BEAM-9283] Add Java 11 Jpms compatibility tests for Spark runner add c4ddb59 Remove change detector tests for Java-on-JRH add 1b4d2ff Make beam_fn_api, use_runner_v2, and use_unified_worker all trigger the same behavior in the SDK add 0619de8 Merge pull request #14226: Eliminate use_runner_v2, and use_unified_worker in the Java SDK, since beam_fn_api suffices add e96f69a Revert "Increase the timeout for ValidatesContainer suite" (#14219) add ff4366d [BEAM-11023] Fix testGroupByKeyWithBadEqualsHashCode failing on Spark Structured Streaming runner add 96bf00a [BEAM-11023] Fix testLargeKeys100MB on Spark Structured Streaming runner add 3ac902a [BEAM-11023] Change access level GroupByKeyTest add 5c9c8c0 Merge pull request #14275: [BEAM-11023] Fix GroupByKeyTest testLargeKeys100MB and testGroupByKeyWithBadEqualsHashCode failing on Spark Structured Streaming runner add e67ba2b [BEAM-5949] Remove trivial __ne__ implementations. (#13887) add 7a60699 Returning successes from FhirIO executeBundles. Needed for healthcare solutions accuracy in logging what was written to the fhir store. add 7f891c3 Syncing with milenas change add ba4a111 Undo formatting changes from Google auto-formatter. add e4768a4 Adding the tuple tag check for FhirIO.Write.Result creation. add 95201ac Updating the contains TupleTag check to use the PCollectionTuple .has() method, casting TupleTagList -> Collection creates an exception for some. add 05f6aaf Fix build add 655b29b Running spotless apply add 61004f3 Merge branch 'master' of https://github.com/apache/beam add 5de886d Merge remote-tracking branch 'upstream/master' add 03d5364 adding LRO counters to import/export/deidentify add 8611174 running spotless apply add 62320cf changing NAME -> KEY after feedback from an internal review add 3bef3da Adding a log statement for when failures occur. add 5f7358d Removing ignores from tests add 1a4cb59 spotless apply add 14f2371 Updating counter names add b2f84d7 Merge pull request #14233 from [BEAM-11733] Adding LRO counters to FhirIO and re-enable FhirIO tests add 93417ce [BEAM-9038] Fix typo for setting_global_window example add 195bbf3 Merge pull request #14271 from [BEAM-9038] Fix typo for setting_global_window example add aa6c075 [BEAM-12010] Create separate merge rules for different Calc implementations. add 3a096ee [BEAM-12010] Use simpler rule constructor so we don't have to pass null. add 49b9d1b Merge pull request #14265 from ibzib/BEAM-12010 No new revisions were added by this update. Summary of changes: ...ommit_CrossLanguageValidatesRunner_Spark.groovy | 1 - ...> job_PostCommit_Java_Jpms_Spark_Java11.groovy} | 8 +- ...ommit_Python_ValidatesContainer_Dataflow.groovy | 2 +- LICENSE| 462 + .../org/apache/beam/gradle/BeamModulePlugin.groovy | 5 +- .../dataflow/DataflowPipelineTranslator.java | 3 +- .../dataflow/DataflowPipelineTranslatorTest.java | 147 --- runners/spark/spark_runner.gradle | 2 + .../org/apache/beam/sdk/transforms/Combine.java| 4 +- .../java/org/apache/beam/sdk/transforms/View.java | 16 +- .../beam/sdk/testing/PCollectionViewTesting.java | 4 +- .../apache/beam/sdk/transforms/GroupByKeyTest.java | 4 +- .../extensions/sql/impl/planner/BeamRuleSet
[beam] branch tvalentyn-patch-1 created (now 0408122)
This is an automated email from the ASF dual-hosted git repository. tvalentyn pushed a change to branch tvalentyn-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. at 0408122 Update names.py This branch includes the following new commits: new 0408122 Update names.py The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[beam] 01/01: Update names.py
This is an automated email from the ASF dual-hosted git repository. tvalentyn pushed a commit to branch tvalentyn-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git commit 040812248185749563ea29f2e511d9696a3b6155 Author: tvalentyn AuthorDate: Thu Mar 18 19:13:08 2021 -0700 Update names.py --- sdks/python/apache_beam/runners/dataflow/internal/names.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/runners/dataflow/internal/names.py b/sdks/python/apache_beam/runners/dataflow/internal/names.py index 81d5fe3..1ca4209 100644 --- a/sdks/python/apache_beam/runners/dataflow/internal/names.py +++ b/sdks/python/apache_beam/runners/dataflow/internal/names.py @@ -41,10 +41,10 @@ SERIALIZED_SOURCE_KEY = 'serialized_source' # Update this version to the next version whenever there is a change that will # require changes to legacy Dataflow worker execution environment. -BEAM_CONTAINER_VERSION = 'beam-master-20210301' +BEAM_CONTAINER_VERSION = 'beam-master-20210318' # Update this version to the next version whenever there is a change that # requires changes to SDK harness container or SDK harness launcher. -BEAM_FNAPI_CONTAINER_VERSION = 'beam-master-20210301' +BEAM_FNAPI_CONTAINER_VERSION = 'beam-master-20210318' DATAFLOW_CONTAINER_IMAGE_REPOSITORY = 'gcr.io/cloud-dataflow/v1beta3'
[beam] branch master updated (195bbf3 -> 49b9d1b)
This is an automated email from the ASF dual-hosted git repository. ibzib pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 195bbf3 Merge pull request #14271 from [BEAM-9038] Fix typo for setting_global_window example new aa6c075 [BEAM-12010] Create separate merge rules for different Calc implementations. new 3a096ee [BEAM-12010] Use simpler rule constructor so we don't have to pass null. new 49b9d1b Merge pull request #14265 from ibzib/BEAM-12010 The 31189 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../extensions/sql/impl/planner/BeamRuleSets.java | 8 +++-- .../BeamCalcMergeRule.java}| 34 +++- .../LogicalCalcMergeRule.java} | 34 +++- .../sql/zetasql/BeamZetaSqlCalcMergeRule.java} | 37 +- .../sql/zetasql/ZetaSQLQueryPlanner.java | 4 ++- 5 files changed, 69 insertions(+), 48 deletions(-) copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/{parser/SqlDropTable.java => rule/BeamCalcMergeRule.java} (60%) copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/{parser/SqlDropTable.java => rule/LogicalCalcMergeRule.java} (63%) copy sdks/java/extensions/sql/{src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropTable.java => zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcMergeRule.java} (59%)
[beam] branch asf-site updated: Publishing website 2021/03/19 00:03:27 at commit 195bbf3
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/asf-site by this push: new 5b5a85e Publishing website 2021/03/19 00:03:27 at commit 195bbf3 5b5a85e is described below commit 5b5a85eee43e9bf4fe5fe95a8952bbbe06f90555 Author: jenkins AuthorDate: Fri Mar 19 00:03:27 2021 + Publishing website 2021/03/19 00:03:27 at commit 195bbf3 --- website/generated-content/documentation/index.xml| 2 +- website/generated-content/documentation/programming-guide/index.html | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/website/generated-content/documentation/index.xml b/website/generated-content/documentation/index.xml index fbf52f9..6ffe472 100644 --- a/website/generated-content/documentation/index.xml +++ b/website/generated-content/documentation/index.xml @@ -7323,7 +7323,7 @@ a single global window for aPCollection
:from apache_beam import window -session_windowed_items = ( +global_windowed_items = ( items | 'window' >> beam.WindowInto(window.GlobalWindows()))