Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-4149

Java SDK Harness should populate worker id in control plane headers

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Minor
    • Resolution: Duplicate
    • Affects Version/s: None
    • Fix Version/s: Not applicable
    • Component/s: sdk-java-harness
    • Labels:
      None

      Description

      The Java 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 control server.

      Note that this affects the Java harness specifically (e.g., when running a local process or in-memory harness). When the harness launched within the docker container, the go boot code takes care of setting this: https://github.com/apache/beam/blob/dffe50924f34d3cc994008703f01e802c99913d2/sdks/java/container/boot.go#L70

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                lcwik Luke Cwik
                Reporter:
                bsidhom Ben Sidhom
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: