[beam] branch feature/autolabeler created (now bcb0d8d)
This is an automated email from the ASF dual-hosted git repository. alexvanboxel pushed a change to branch feature/autolabeler in repository https://gitbox.apache.org/repos/asf/beam.git. at bcb0d8d Added newline at the end of the file This branch includes the following new commits: new bcb0d8d Added newline at the end of the file 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: Added newline at the end of the file
This is an automated email from the ASF dual-hosted git repository. alexvanboxel pushed a commit to branch feature/autolabeler in repository https://gitbox.apache.org/repos/asf/beam.git commit bcb0d8da909963a19492aeadec1bc5a0eb7465b6 Author: Alex Van Boxel AuthorDate: Tue Feb 11 08:38:21 2020 +0100 Added newline at the end of the file --- .github/autolabeler.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/autolabeler.yml b/.github/autolabeler.yml index e8d7754..8ea389f 100644 --- a/.github/autolabeler.yml +++ b/.github/autolabeler.yml @@ -23,4 +23,4 @@ java: ["sdks/java/*"] python: ["sdks/python/*"] runner: ["runners/*"] examples: ["examples/*", "learning/*"] -model: ["model/*"] \ No newline at end of file +model: ["model/*"]
[beam] branch master updated (da9e172 -> e24d1e5)
This is an automated email from the ASF dual-hosted git repository. apilloud pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from da9e172 Merge pull request #10739: [BEAM-9231] Annotate as Experimental/Internal missing classes in beam-sdks-java-core add e527bec [BEAM-8630] Validate prepared expression on expand add e24d1e5 Merge pull request #10820: [BEAM-8630] Validate prepared expression on expand No new revisions were added by this update. Summary of changes: .../apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcRel.java | 5 - 1 file changed, 4 insertions(+), 1 deletion(-)
[beam] branch master updated (7fc5fb5 -> da9e172)
This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 7fc5fb5 Merge pull request #10746: [BEAM-9241] Fix inconsistent proto nullability add e96dbf3 [BEAM-9231] Add Experimental(Kind.PORTABILITY) and tag related classes add 650e6cd [BEAM-9231] Tag SplittableDoFn related classes/methods as Experimental add 9108832 [BEAM-9231] Make Experimental annotations homogeneous in beam-sdks-java-core add cb7cb53 [BEAM-9231] Untag Experimental/Internal classes not needed to write pipelines add 1574a81 [BEAM-9231] Tag beam-sdks-java-core internal classes as Internal add 0b2d2f5 [BEAM-9231] Tag DoFn.OnTimerContext as Experimental(Kind.TIMERS) add 486d230 [BEAM-9231] Tag Experimental/Internal packages in beam-sdks-java-core add a90ef1a [BEAM-9231] Tag Experimental/Internal packages in IOs and extensions add ce35107 [BEAM-9231] Tag public but internal IOs and extensions classes as Internal add da9e172 Merge pull request #10739: [BEAM-9231] Annotate as Experimental/Internal missing classes in beam-sdks-java-core No new revisions were added by this update. Summary of changes: .../runners/core/construction/CoderTranslator.java | 3 -- .../core/construction/CoderTranslators.java| 3 -- .../beam/runners/core/construction/External.java | 3 ++ .../core/construction/PTransformMatchers.java | 3 -- .../runners/core/construction/SdkComponents.java | 2 - .../runners/core/construction/SplittableParDo.java | 2 - .../core/construction/TriggerTranslation.java | 2 - .../core/construction/graph/ProtoOverrides.java| 2 - .../beam/runners/core/InMemoryStateInternals.java | 3 -- .../beam/runners/core/MergingStateAccessor.java| 3 -- .../apache/beam/runners/core/StateAccessor.java| 3 -- .../apache/beam/runners/core/StateInternals.java | 3 -- .../beam/runners/core/StateInternalsFactory.java | 3 -- .../org/apache/beam/runners/core/StateTag.java | 3 -- .../org/apache/beam/runners/core/StateTags.java| 3 -- .../beam/runners/core/TimerInternalsFactory.java | 3 -- .../beam/runners/core/metrics/CounterCell.java | 5 --- .../beam/runners/core/metrics/DirtyState.java | 5 --- .../runners/core/metrics/DistributionCell.java | 5 --- .../beam/runners/core/metrics/GaugeCell.java | 4 -- .../beam/runners/core/metrics/MetricCell.java | 3 -- .../beam/runners/core/metrics/MetricUpdates.java | 3 -- .../runners/core/metrics/MetricsContainerImpl.java | 3 -- .../beam/runners/core/metrics/MetricsMap.java | 3 -- .../beam/runners/core/metrics/MetricsPusher.java | 2 - .../runners/core/metrics/MetricsTranslation.java | 3 -- .../core/triggers/AfterAllStateMachine.java| 2 - .../AfterDelayFromFirstElementStateMachine.java| 2 - .../core/triggers/AfterFirstStateMachine.java | 2 - .../core/triggers/AfterPaneStateMachine.java | 2 - .../triggers/AfterProcessingTimeStateMachine.java | 2 - .../core/triggers/AfterWatermarkStateMachine.java | 2 - .../core/triggers/DefaultTriggerStateMachine.java | 2 - .../java/org/apache/beam/runners/direct/Clock.java | 2 - .../beam/runners/direct/DirectTestOptions.java | 2 - .../beam/runners/direct/WatermarkManager.java | 2 - .../extensions/metrics/MetricsGraphiteSink.java| 2 - .../extensions/metrics/MetricsHttpSink.java| 2 - .../beam/runners/dataflow/DataflowRunner.java | 2 - .../beam/runners/dataflow/TransformTranslator.java | 2 - .../options/DataflowPipelineWorkerPoolOptions.java | 5 ++- .../beam/runners/dataflow/util/PackageUtil.java| 2 - .../jobsubmission/PortablePipelineResult.java | 2 - .../beam/runners/samza/state/SamzaMapState.java| 2 - .../beam/runners/samza/state/SamzaSetState.java| 2 - .../SparkStructuredStreamingRunner.java| 2 - .../runners/spark/translation/SparkCombineFn.java | 2 - .../beam/runners/spark/util/SparkCompat.java | 2 - .../apache/beam/sdk/annotations/Experimental.java | 4 ++ .../org/apache/beam/sdk/annotations/Internal.java | 1 + .../apache/beam/sdk/annotations/package-info.java | 1 + .../sdk/expansion/ExternalTransformRegistrar.java | 3 +- .../apache/beam/sdk/expansion/package-info.java| 3 ++ .../org/apache/beam/sdk/harness/package-info.java | 2 + .../main/java/org/apache/beam/sdk/io/AvroIO.java | 4 +- .../java/org/apache/beam/sdk/io/AvroSource.java| 7 ++-- .../org/apache/beam/sdk/io/BlockBasedSource.java | 7 ++-- .../java/org/apache/beam/sdk/io/BoundedSource.java | 3 +- .../org/apache/beam/sdk/io/CompressedSource.java | 3 +- .../main/java/org/apache/beam/sdk/io/FileIO.java | 7 ++-- .../beam/sdk/io/ReadAllViaFileBasedSource.java | 3 +- .../main/java/org/apache/beam/sdk/io/Source.java | 3 +-
[beam] branch master updated (aa1142a -> 7fc5fb5)
This is an automated email from the ASF dual-hosted git repository.
alexvanboxel pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from aa1142a Merge pull request #10798 from robertwb/provision
add aab5ae5 [BEAM-9241] Fix inconsistent proto nullability
add 7fc5fb5 Merge pull request #10746: [BEAM-9241] Fix inconsistent proto
nullability
No new revisions were added by this update.
Summary of changes:
.../extensions/protobuf/ProtoSchemaTranslator.java | 39 --
.../protobuf/ProtoMessageSchemaTest.java | 50 +++-
.../protobuf/ProtoSchemaTranslatorTest.java| 28 +
.../sdk/extensions/protobuf/TestProtoSchemas.java | 136 ++---
...messages.proto => proto2_schema_messages.proto} | 38 +++---
5 files changed, 216 insertions(+), 75 deletions(-)
copy
sdks/java/extensions/protobuf/src/test/proto/{proto2_coder_test_messages.proto
=> proto2_schema_messages.proto} (59%)
[beam] branch master updated (995d0ae -> aa1142a)
This is an automated email from the ASF dual-hosted git repository. robertwb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 995d0ae Merge pull request #10805 Reject unsupported WindowFns and Window types. new 065ada9 [BEAM-9266] Remove unused fields from provisioning API. new 3bd2911 Remove one more reference to provision resources. new aa1142a Merge pull request #10798 from robertwb/provision The 25493 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: .../src/main/proto/beam_provision_api.proto| 48 -- .../runners/fnexecution/provisioning/JobInfo.java | 2 - .../StaticGrpcProvisionServiceTest.java| 19 + sdks/java/container/boot.go| 3 -- .../runners/portability/fn_api_runner.py | 11 ++--- .../runners/portability/local_job_service.py | 9 ++-- 6 files changed, 8 insertions(+), 84 deletions(-)
[beam] branch master updated (cb1d4e7 -> 995d0ae)
This is an automated email from the ASF dual-hosted git repository. robertwb pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from cb1d4e7 [BEAM-9268] SpannerIO: Add more documentation and warnings for unknown tables. (#10690) add d39a37a Reject unsupported WindowFns and Window types. add 995d0ae Merge pull request #10805 Reject unsupported WindowFns and Window types. No new revisions were added by this update. Summary of changes: .../runners/dataflow/dataflow_runner.py| 21 .../runners/dataflow/dataflow_runner_test.py | 23 ++ 2 files changed, 44 insertions(+)
[beam] branch master updated (2ea6e00 -> cb1d4e7)
This is an automated email from the ASF dual-hosted git repository. chamikara pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 2ea6e00 Merge pull request #10812: [BEAM-7092] Fix invalid import of Guava coming from transitive Spark dep add cb1d4e7 [BEAM-9268] SpannerIO: Add more documentation and warnings for unknown tables. (#10690) No new revisions were added by this update. Summary of changes: .../sdk/io/gcp/spanner/MutationKeyEncoder.java | 46 +--- .../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 34 +++- .../sdk/io/gcp/spanner/MutationKeyEncoderTest.java | 61 +++--- 3 files changed, 117 insertions(+), 24 deletions(-)
[beam] branch master updated (a005fd7 -> 2ea6e00)
This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from a005fd7 Merge pull request #10627:[BEAM-2535] Support outputTimestamp and watermark holds in processing timers. add 616fb53 [BEAM-7092] Fix invalid import of Guava coming from transitive Spark dep add 2ea6e00 Merge pull request #10812: [BEAM-7092] Fix invalid import of Guava coming from transitive Spark dep No new revisions were added by this update. Summary of changes: .../beam/runners/spark/translation/TransformTranslatorTest.java | 2 +- sdks/java/build-tools/src/main/resources/beam/checkstyle.xml | 8 2 files changed, 9 insertions(+), 1 deletion(-)
[beam] branch charlesccychen-patch-1 updated (04e3eb5 -> e8f9064)
This is an automated email from the ASF dual-hosted git repository. ccy pushed a change to branch charlesccychen-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. from 04e3eb5 Update interactive_utils.py add e8f9064 Update interactive_utils.py No new revisions were added by this update. Summary of changes: sdks/python/apache_beam/utils/interactive_utils.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-)
[beam] branch charlesccychen-patch-1 updated (a4705e0 -> 04e3eb5)
This is an automated email from the ASF dual-hosted git repository. ccy pushed a change to branch charlesccychen-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. from a4705e0 [BEAM-9277] Fix exception when running in IPython notebook add 04e3eb5 Update interactive_utils.py No new revisions were added by this update. Summary of changes: sdks/python/apache_beam/utils/interactive_utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[beam] 01/01: [BEAM-9277] Fix exception when running in IPython notebook
This is an automated email from the ASF dual-hosted git repository. ccy pushed a commit to branch charlesccychen-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git commit a4705e07e037fb76f39e02189706f2e85f202033 Author: Charles Chen AuthorDate: Mon Feb 10 00:06:56 2020 -0800 [BEAM-9277] Fix exception when running in IPython notebook --- sdks/python/apache_beam/utils/interactive_utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/utils/interactive_utils.py b/sdks/python/apache_beam/utils/interactive_utils.py index f00c7b1..bef7566 100644 --- a/sdks/python/apache_beam/utils/interactive_utils.py +++ b/sdks/python/apache_beam/utils/interactive_utils.py @@ -81,7 +81,7 @@ def alter_label_if_ipython(transform, pvalueish): _LOGGER.warning( 'Failed to alter the label of a transform with the ' 'ipython prompt metadata. Cannot figure out the pipeline ' - 'that the given pvalueish %s belongs to. Thus noop.' % pvalueish) + 'that the given pvalueish %s belongs to. Thus noop.' % (pvalueish,)) if (pipeline # We only alter for transforms to be applied to user-defined pipelines # at pipeline construction time.
[beam] branch charlesccychen-patch-1 created (now a4705e0)
This is an automated email from the ASF dual-hosted git repository. ccy pushed a change to branch charlesccychen-patch-1 in repository https://gitbox.apache.org/repos/asf/beam.git. at a4705e0 [BEAM-9277] Fix exception when running in IPython notebook This branch includes the following new commits: new a4705e0 [BEAM-9277] Fix exception when running in IPython notebook 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.
