com.google.cloud.dataflow.sdk.coders.CoderException：无法编码空字符串

我在 Google Cloud 数据流中收到以下错误：

java.lang.RuntimeException：com.google.cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：com.google.cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：com.google。 cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：java.lang.RuntimeException：com.google.cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：java.lang.RuntimeException：com. google.cloud.dataflow.sdk.coders.CoderException：无法在 com.google.cloud.dataflow.sdk.runners.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:162) 处编码空字符串 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase$DoFnContext.outputWindowedValue(DoFnRunnerBase.java:287) 位于 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase$DoFnProcessContext.output（DoFnRunnerBase.java:449）位于 reports.transforms.JsonToObject.processElement(JsonToObject.java:35)

引起原因：com.google.cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：com.google.cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：com.google.cloud.dataflow .sdk.util.UserCodeException：java.lang.RuntimeException：java.lang.RuntimeException：com.google.cloud.dataflow.sdk.util.UserCodeException：java.lang.RuntimeException：java.lang.RuntimeException：com.google.cloud .dataflow.sdk.coders.CoderException：无法在 com.google.cloud.dataflow.sdk.util.UserCodeException.wrap(UserCodeException.java:35) 处对 com.google.cloud.dataflow.sdk.util 处的空字符串进行编码。 UserCodeException.wrapIf(UserCodeException.java:40) 在 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase.wrapUserCodeException(DoFnRunnerBase.java:368) 在 com.google.cloud.dataflow.sdk.util.SimpleDoFnRunner.invokeProcessElement( SimpleDoFnRunner.java:51) 在 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase.processElement(DoFnRunnerBase.java:138) 在 com.google.cloud.dataflow.sdk.runners.worker.SimpleParDoFn.processElement(SimpleParDoFn. java：190）在com.google.cloud.dataflow.sdk.runners.worker.ForwardingParDoFn.processElement（ForwardingParDoFn.java：42）在com.google.cloud.dataflow.sdk.runners.worker.DataflowWorkerLoggingParDoFn.processElement（DataflowWorkerLoggingParDoFn。 java:47) 在 com.google.cloud.dataflow.sdk.util.common.worker.ParDoOperation.process(ParDoOperation.java:53) 在 com.google.cloud.dataflow.sdk.util.common.worker.OutputReceiver.process（OutputReceiver.java:52）位于 com.google.cloud.dataflow.sdk.runners.worker.SimpleParDoFn$1.output(SimpleParDoFn.java:160) 在 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase$DoFnContext.outputWindowedValue(DoFnRunnerBase.java:287) 位于 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase$DoFnProcessContext.output（DoFnRunnerBase.java:449）位于 reports.transforms.JsonToObject.processElement(JsonToObject.java:35) 在 com.google.cloud.dataflow.sdk.util.SimpleDoFnRunner.invokeProcessElement（SimpleDoFnRunner.java:49）位于 com.google.cloud.dataflow.sdk.util.DoFnRunnerBase.processElement(DoFnRunnerBase.java:138)

在我的类（JsonToObject）中，我执行以下操作：

if (obj != null) { processContext.output(obj); }

以及抛出异常的地方。

知道为什么会发生吗？

可空编码器 https://cloud.google.com/dataflow/java-sdk/JavaDoc/com/google/cloud/dataflow/sdk/coders/NullableCoder是一个复合编码器，需要用另一个编码器来指定它。@DefaultCoder https://cloud.google.com/dataflow/java-sdk/JavaDoc/com/google/cloud/dataflow/sdk/coders/DefaultCoder与复合编码器（KvCoder，IterableCoder，...）不兼容，因为需要由另一个编码器参数化。解决问题的一种方法是在每个可能包含可为空类型的 PCollection 上手动设置编码器。例如：

PCollection<String> pc = pipeline.apply(... transform that produces nulls ...);
pc.setCoder(NullableCoder.of(StringUtf8Coder.of());