[BEAM-3976] SdkHarnessClient is thread-safe

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Not A Problem
• Fix Version/s: Not applicable
• Component/s: runner-core
• Assignee: Axel Magnuson
• Reporter: Ben Sidhom
• Created: 30/Mar/18 20:44
• Updated: 16/May/20 13:58
• Resolved: 30/Mar/18 21:20

Description

In general, we want to share access to a given SDK harness among multiple runner workers as a way to amortize container startup and resource costs. Because control messages are multiplexed over the same shared control connection, this sharing currently requires external locking on the same shared lock object. This is error-prone and difficult to verify. The SdkHarnesClient should use internal mechanisms to provide thread-safety.

Issue Links

• is depended upon by: BEAM-2889 Flink runs portable pipelines