[
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)
