[
https://issues.apache.org/jira/browse/BEAM-7676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877288#comment-16877288
]
Kyle Weaver commented on BEAM-7676:
-----------------------------------
cc: [~angoenka]
> 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
>
> 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
(v7.6.3#76005)
