You are viewing a plain text version of this content. The canonical link for it is here.

Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2020/06/26 23:05:50 UTC

[GitHub] [beam] youngoli commented on a change in pull request #12095: [BEAM-10311] Sharing restriction trackers between SDF and DataSource.

youngoli commented on a change in pull request #12095:
URL: https://github.com/apache/beam/pull/12095#discussion_r446445983



##########
File path: sdks/go/pkg/beam/core/runtime/exec/sdf.go
##########
@@ -217,6 +218,11 @@ type ProcessSizedElementsAndRestrictions struct {
 	PDo *ParDo
 
 	inv *ctInvoker
+
+	// rt allows this unit to send out restriction trackers being processed.

Review comment:
       Fixed. (Also switched the channel from `*RTracker` to `RTracker`)




----------------------------------------------------------------
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:
users@infra.apache.org