[
https://issues.apache.org/jira/browse/BEAM-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kyle Weaver resolved BEAM-7676.
-------------------------------
Fix Version/s: 2.16.0
Resolution: Fixed
> All SDK workers have worker_id="1"
> ----------------------------------
>
> Key: BEAM-7676
> URL: https://issues.apache.org/jira/browse/BEAM-7676
> Project: Beam
> Issue Type: Improvement
> Components: runner-flink
> Reporter: Kyle Weaver
> Assignee: Kyle Weaver
> Priority: Minor
> Fix For: 2.16.0
>
> Time Spent: 1h
> Remaining Estimate: 0h
>
> SDK workers are created using multiple job factories, which all give their
> initial workers id 1 [1]. We could perhaps identify sdk workers also by the
> factory that created them, for example worker_id=$FACTORY-$WORKER (e.g.
> worker_id="1-1", "1-2"..."2-1"...)
>
> [1]
> [https://github.com/apache/beam/blob/89b08e133be5a2c6bcdbd36242f16ef7ab796902/runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java#L115]
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
