Skip to content

Make Portable ULR use workerId in GRPC channel #18850

@kennknowles

Description

@kennknowles

The internal implementation of Data service uses workerId make sure that 

https://github.com/apache/beam/blob/master/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java

Also uses workerId.

Imported from Jira BEAM-4219. Original Jira may contain additional context.
Reported by: angoenka.

Metadata

Metadata

Assignees

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions