Details
-
Improvement
-
Status: Resolved
-
P4
-
Resolution: Fixed
-
None
-
None
Description
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.