[ https://issues.apache.org/jira/browse/BEAM-4149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17078805#comment-17078805 ]
Robert Bradshaw commented on BEAM-4149: --------------------------------------- Updating Python SDKs to handle the non-stream-stream case was done in https://github.com/apache/beam/pull/11235 . These get added to the channel factory in Java at https://github.com/apache/beam/blob/release-2.20.0/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java > SDK Harness should populate worker id in RPC headers > ---------------------------------------------------- > > Key: BEAM-4149 > URL: https://issues.apache.org/jira/browse/BEAM-4149 > Project: Beam > Issue Type: Bug > Components: sdk-java-harness > Reporter: Ben Sidhom > Assignee: Robert Bradshaw > Priority: Minor > Fix For: Not applicable > > > The SDK harness currently does nothing to populate control plane headers with > the harness worker id. This id is necessary in order to identify harnesses > when multiple are run from the same runner server. > Note that this affects the _SDK_ harness specifically (e.g., when running a > local process or in-memory harness). -- This message was sent by Atlassian Jira (v8.3.4#803005)