[
https://issues.apache.org/jira/browse/BEAM-7507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Cwik closed BEAM-7507.
---------------------------
Resolution: Fixed
Fix Version/s: 2.14.0
> StreamingDataflowWorker attempts to decode non-utf8 binary data as utf8
> -----------------------------------------------------------------------
>
> Key: BEAM-7507
> URL: https://issues.apache.org/jira/browse/BEAM-7507
> Project: Beam
> Issue Type: Improvement
> Components: runner-dataflow
> Reporter: Steve Niemitz
> Assignee: Steve Niemitz
> Priority: Trivial
> Fix For: 2.14.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> In StreamingDataflowWorker, when setting the workId for the logging MDC,
> currently the code attempts to decode a binary blob as utf8. This will
> (generally) cause a decoding error, and the java UTF8 decoder uses a globally
> synchronized cache to handle generating these error results.
> A simple solution would be to use the protobuf TextFormat escaping to convert
> the ByteString key into a string.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
