Hello, I am trying to build a pipeline using Beam's Python SDK to run on Dataflow and I encountered an error when encoding Null value message coming from kafka (tombstone message)
``` Caused by: org.apache.beam.sdk.coders.CoderException: cannot encode a null byte[] ``` It seems unsupported for the moment, as I saw here <https://github.com/apache/beam/blob/243128a8fc52798e1b58b0cf1a271d95ee7aa241/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteArrayCoder.java#L63> Is there a workaround for this? To avoid having errors pop up each time a null-value message arrives? Or to bypass these events? jira ticket that might be related here <https://issues.apache.org/jira/browse/BEAM-10529> slack message here <https://the-asf.slack.com/archives/C9H0YNP3P/p1648226359872819> Kind regards, Abdelhakim Bendjabeur Data Engineer @gorgias
