Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion sdks/go/pkg/beam/core/runtime/harness/datamgr.go
Original file line number Diff line number Diff line change
Expand Up @@ -433,7 +433,7 @@ func (c *DataChannel) read(ctx context.Context) {
// for all transforms in an instruction before the instruction even begun. However, we can't
// know this until we received the Control instruction which knows how many transforms for which
// we need to receive data. So we check the cache directly every so often and evict closed
// readers. We will never recieve data for these instructions again.
// readers. We will never receive data for these instructions again.
for instID, r := range cache {
if r.Closed() {
delete(cache, instID)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -299,7 +299,7 @@ func (tsi *testStreamImpl) initHandler(id string) {
}
}

// TagsToPCollections recieves the map of local output tags to global pcollection ids.
// TagsToPCollections receives the map of local output tags to global pcollection ids.
func (tsi *testStreamImpl) TagsToPCollections(tagToPcol map[string]string) {
tsi.em.testStreamHandler.TagsToPCollections(tagToPcol)
}
Expand Down
Loading