[GitHub] [beam] darshanj commented on pull request #11610: [BEAM-9825] | Implement Intersect,Union,Except transforms
darshanj commented on pull request #11610: URL: https://github.com/apache/beam/pull/11610#issuecomment-626458097 @amaliujia @robertwb : Do we verify WindowFns for all pCollections to be the same with first in the list? This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] Hannah-Jiang commented on pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
Hannah-Jiang commented on pull request #11656: URL: https://github.com/apache/beam/pull/11656#issuecomment-626455433 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] Hannah-Jiang commented on pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
Hannah-Jiang commented on pull request #11656: URL: https://github.com/apache/beam/pull/11656#issuecomment-626455310 Run Portable_Python PreCommit This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] stale[bot] commented on pull request #10480: [BEAM-8932][Cleanup] Extract IncomingMessage and OutgoingMessage from PubsubClient
stale[bot] commented on pull request #10480: URL: https://github.com/apache/beam/pull/10480#issuecomment-62639 This pull request has been marked as stale due to 60 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull request requires a review, please simply write any comment. If closed, you can revive the PR at any time and @mention a reviewer or discuss it on the d...@beam.apache.org list. Thank you for your contributions. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] stale[bot] commented on pull request #10479: [BEAM-8932][Cleanup] Change default PubsubIO client from json to grpc.
stale[bot] commented on pull request #10479: URL: https://github.com/apache/beam/pull/10479#issuecomment-626388316 This pull request has been marked as stale due to 60 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull request requires a review, please simply write any comment. If closed, you can revive the PR at any time and @mention a reviewer or discuss it on the d...@beam.apache.org list. Thank you for your contributions. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] stale[bot] commented on pull request #10808: [BEAM-8932] Modify PubsubUnboundedSource and PubsubReader to use the PubsubMessage proto.
stale[bot] commented on pull request #10808: URL: https://github.com/apache/beam/pull/10808#issuecomment-626388322 This pull request has been marked as stale due to 60 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull request requires a review, please simply write any comment. If closed, you can revive the PR at any time and @mention a reviewer or discuss it on the d...@beam.apache.org list. Thank you for your contributions. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] stale[bot] commented on pull request #10809: [BEAM-8932] Add MessageWithOrderingKey and add a usable method to generate a PCollection with this type.
stale[bot] commented on pull request #10809: URL: https://github.com/apache/beam/pull/10809#issuecomment-626388313 This pull request has been marked as stale due to 60 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull request requires a review, please simply write any comment. If closed, you can revive the PR at any time and @mention a reviewer or discuss it on the d...@beam.apache.org list. Thank you for your contributions. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] stale[bot] commented on pull request #10807: [BEAM-8932][Cleanup] Fix metric reader to use an actually accessible Nonnull annotation.
stale[bot] commented on pull request #10807: URL: https://github.com/apache/beam/pull/10807#issuecomment-626388319 This pull request has been marked as stale due to 60 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pull request requires a review, please simply write any comment. If closed, you can revive the PR at any time and @mention a reviewer or discuss it on the d...@beam.apache.org list. Thank you for your contributions. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lostluck opened a new pull request #11657: Add License file for the Go SDK for pkg.go.dev
lostluck opened a new pull request #11657: URL: https://github.com/apache/beam/pull/11657 This permits the SDK content and document to appear on https://pkg.go.dev/ per https://pkg.go.dev/license-policy Content for the file was automatically provided by github's license tool. **Please** add a meaningful description for your change here Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R: @username`). - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue. - [ ] Update `CHANGES.md` with noteworthy changes. - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf). See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/#make-reviewers-job-easier). Post-Commit Tests Status (on master branch) Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark --- | --- | --- | --- | --- | --- | --- | --- Go | [](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) Java | [](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[![Build
[GitHub] [beam] lostluck commented on pull request #11657: Add License file for the Go SDK for pkg.go.dev
lostluck commented on pull request #11657: URL: https://github.com/apache/beam/pull/11657#issuecomment-626381872 R: @youngoli This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lostluck commented on a change in pull request #11645: [BEAM-9642] Adding Go SDF fallback for unexpanded SDFs.
lostluck commented on a change in pull request #11645:
URL: https://github.com/apache/beam/pull/11645#discussion_r422682835
##
File path: sdks/go/pkg/beam/core/runtime/exec/sdf.go
##
@@ -313,3 +313,94 @@ func (n *ProcessSizedElementsAndRestrictions) Down(ctx
context.Context) error {
func (n *ProcessSizedElementsAndRestrictions) String() string {
return fmt.Sprintf("SDF.ProcessSizedElementsAndRestrictions[%v]
Out:%v", path.Base(n.PDo.Fn.Name()), IDs(n.PDo.Out...))
}
+
+// SdfFallback is an executor used when an SDF isn't expanded into steps by the
+// runner, indicating that the runner doesn't support splitting. It executes
all
+// the SDF steps together in one unit.
+type SdfFallback struct {
+ PDo *ParDo
+
+ initRestInv *cirInvoker
+ splitInv*srInvoker
+ trackerInv *ctInvoker
+}
+
+// ID just defers to the ParDo's ID method.
+func (n *SdfFallback) ID() UnitID {
+ return n.PDo.UID
+}
+
+// Up performs some one-time setup and then defers to the ParDo's Up method.
+func (n *SdfFallback) Up(ctx context.Context) error {
+ sdf := (*graph.SplittableDoFn)(n.PDo.Fn)
+ addContext := func(err error) error {
+ return errors.WithContextf(err, "SdfFallback transform with UID
%v", n.ID())
Review comment:
Consider just using the auto String() print to add as context instead of
adding the extra words. eg. (err, "%v", n)
##
File path: sdks/go/pkg/beam/core/runtime/exec/sdf.go
##
@@ -313,3 +313,94 @@ func (n *ProcessSizedElementsAndRestrictions) Down(ctx
context.Context) error {
func (n *ProcessSizedElementsAndRestrictions) String() string {
return fmt.Sprintf("SDF.ProcessSizedElementsAndRestrictions[%v]
Out:%v", path.Base(n.PDo.Fn.Name()), IDs(n.PDo.Out...))
}
+
+// SdfFallback is an executor used when an SDF isn't expanded into steps by the
+// runner, indicating that the runner doesn't support splitting. It executes
all
+// the SDF steps together in one unit.
+type SdfFallback struct {
+ PDo *ParDo
+
+ initRestInv *cirInvoker
+ splitInv*srInvoker
+ trackerInv *ctInvoker
+}
+
+// ID just defers to the ParDo's ID method.
+func (n *SdfFallback) ID() UnitID {
+ return n.PDo.UID
+}
+
+// Up performs some one-time setup and then defers to the ParDo's Up method.
+func (n *SdfFallback) Up(ctx context.Context) error {
+ sdf := (*graph.SplittableDoFn)(n.PDo.Fn)
+ addContext := func(err error) error {
+ return errors.WithContextf(err, "SdfFallback transform with UID
%v", n.ID())
+ }
+ var err error
+ if n.initRestInv, err =
newCreateInitialRestrictionInvoker(sdf.CreateInitialRestrictionFn()); err !=
nil {
+ return addContext(err)
+ }
+ if n.splitInv, err =
newSplitRestrictionInvoker(sdf.SplitRestrictionFn()); err != nil {
+ return addContext(err)
+ }
+ if n.trackerInv, err = newCreateTrackerInvoker(sdf.CreateTrackerFn());
err != nil {
+ return addContext(err)
+ }
+ return n.PDo.Up(ctx)
+}
+
+// StartBundle just defers to the ParDo's StartBundle method.
Review comment:
Editorial nits:
We can probably remove the "just".
Given "defer" is a keyword in Go, using defers might be misinterpreted.
Consider replacing it with "calls"
```suggestion
// StartBundle calls the ParDo's StartBundle method.
```
##
File path: sdks/go/pkg/beam/core/runtime/exec/sdf.go
##
@@ -313,3 +313,94 @@ func (n *ProcessSizedElementsAndRestrictions) Down(ctx
context.Context) error {
func (n *ProcessSizedElementsAndRestrictions) String() string {
return fmt.Sprintf("SDF.ProcessSizedElementsAndRestrictions[%v]
Out:%v", path.Base(n.PDo.Fn.Name()), IDs(n.PDo.Out...))
}
+
+// SdfFallback is an executor used when an SDF isn't expanded into steps by the
+// runner, indicating that the runner doesn't support splitting. It executes
all
+// the SDF steps together in one unit.
+type SdfFallback struct {
+ PDo *ParDo
+
+ initRestInv *cirInvoker
+ splitInv*srInvoker
+ trackerInv *ctInvoker
+}
+
+// ID just defers to the ParDo's ID method.
+func (n *SdfFallback) ID() UnitID {
+ return n.PDo.UID
+}
+
+// Up performs some one-time setup and then defers to the ParDo's Up method.
+func (n *SdfFallback) Up(ctx context.Context) error {
+ sdf := (*graph.SplittableDoFn)(n.PDo.Fn)
+ addContext := func(err error) error {
+ return errors.WithContextf(err, "SdfFallback transform with UID
%v", n.ID())
+ }
+ var err error
+ if n.initRestInv, err =
newCreateInitialRestrictionInvoker(sdf.CreateInitialRestrictionFn()); err !=
nil {
+ return addContext(err)
+ }
+ if n.splitInv, err =
newSplitRestrictionInvoker(sdf.SplitRestrictionFn()); err != nil {
+ return addContext(err)
+ }
+ if n.trackerInv, err =
[GitHub] [beam] rose-rong-liu commented on pull request #11075: [BEAM-9421] Website section that describes getting predictions using AI Platform Prediciton
rose-rong-liu commented on pull request #11075: URL: https://github.com/apache/beam/pull/11075#issuecomment-626366484 Public tfx_bsl interface will be out in the next release (0.22) next week. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lazylynx commented on pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
lazylynx commented on pull request #11656: URL: https://github.com/apache/beam/pull/11656#issuecomment-626322075 CC: @kamilwu This PR may affect your work with BEAM-9810 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lazylynx commented on pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
lazylynx commented on pull request #11656: URL: https://github.com/apache/beam/pull/11656#issuecomment-626321914 R: @tvalentyn This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lazylynx removed a comment on pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
lazylynx removed a comment on pull request #11656: URL: https://github.com/apache/beam/pull/11656#issuecomment-626321590 Run Python PreCommit This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lazylynx commented on pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
lazylynx commented on pull request #11656: URL: https://github.com/apache/beam/pull/11656#issuecomment-626321590 Run Python PreCommit This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] lazylynx opened a new pull request #11656: [BEAM-9942] reduce groovy code duplication in python test-suites
lazylynx opened a new pull request #11656: URL: https://github.com/apache/beam/pull/11656 Reduced Python test-suites code duplication for easy introduce of new Python versions. Test-suites for Python 2 which are not applying common.gradle are left as it is considering Python 2.7 support will be dropped in the near future. And tests specific version tied like `hdfsIntegrationTest` will be modified version-switchable in another PR. Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R: @username`). - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue. - [ ] Update `CHANGES.md` with noteworthy changes. - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf). See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/#make-reviewers-job-easier). Post-Commit Tests Status (on master branch) Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark --- | --- | --- | --- | --- | --- | --- | --- Go | [](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) Java | [](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[![Build
[GitHub] [beam] matthiasa4 commented on pull request #11654: [BEAM-9930] Correct authors of beam summit digital blog post
matthiasa4 commented on pull request #11654: URL: https://github.com/apache/beam/pull/11654#issuecomment-626304409 Thanks Max! This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] mxm commented on pull request #11655: [BEAM-9930] Add image to Beam Summit blog post
mxm commented on pull request #11655: URL: https://github.com/apache/beam/pull/11655#issuecomment-626303949 CC @matthiasa4 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] mxm opened a new pull request #11655: [BEAM-9930] Add image to Beam Summit blog post
mxm opened a new pull request #11655: URL: https://github.com/apache/beam/pull/11655 Post-Commit Tests Status (on master branch) Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark --- | --- | --- | --- | --- | --- | --- | --- Go | [](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) Java | [](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/) Python | [](https://builds.apache.org/job/beam_PostCommit_Python2/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Python35/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Python36/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Python37/lastCompletedBuild/) | --- | [](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2/lastCompletedBuild/)[![Build
[GitHub] [beam] mxm commented on pull request #11654: [BEAM-9930] Correct authors of beam summit digital blog post
mxm commented on pull request #11654: URL: https://github.com/apache/beam/pull/11654#issuecomment-626300625 Now fixed: https://apache-beam-website-pull-requests.storage.googleapis.com/11654/blog/2020/05/08/beam-summit-digital-2020.html This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GitHub] [beam] mxm opened a new pull request #11654: [BEAM-9930] Correct authors of beam summit digital blog post
mxm opened a new pull request #11654: URL: https://github.com/apache/beam/pull/11654 The authors are not shown correctly. Post-Commit Tests Status (on master branch) Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark --- | --- | --- | --- | --- | --- | --- | --- Go | [](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) Java | [](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/) Python | [](https://builds.apache.org/job/beam_PostCommit_Python2/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Python35/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Python36/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Python37/lastCompletedBuild/) | --- | [](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Py_VR_Dataflow_V2/lastCompletedBuild/)[![Build
[GitHub] [beam] mxm commented on pull request #11654: [BEAM-9930] Correct authors of beam summit digital blog post
mxm commented on pull request #11654: URL: https://github.com/apache/beam/pull/11654#issuecomment-626297756 CC @matthiasa4 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
