Looking into [some remaining failures in
ReferenceRunnerTest](https://storage.googleapis.com/runsascoded-tmp/beam/ReferenceRunnerTest-1536522471/classes/org.apache.beam.runners.direct.portable.ReferenceRunnerTest.html#pipelineExecution):
**pipelineExecution** / **GBK**:
```
java.lang.NullPointerException: No evaluator for PTransform
"beam:transform:group_by_key:v1"
at
com.google.common.base.Preconditions.checkNotNull(Preconditions.java:864)
at
org.apache.beam.runners.direct.portable.TransformEvaluatorRegistry.forApplication(TransformEvaluatorRegistry.java:96)
at
org.apache.beam.runners.direct.portable.DirectTransformExecutor.run(DirectTransformExecutor.java:93)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
```
**testSDF**:
```
java.lang.IllegalArgumentException: PCollectionNodes
[PCollectionNode{id=ParDo(PairStringWithIndexToLength)/ParMultiDo(PairStringWithIndexToLength).output,
PCollection=unique_name:
"ParDo(PairStringWithIndexToLength)/ParMultiDo(PairStringWithIndexToLength).output"
coder_id: "KvCoder7"
is_bounded: UNBOUNDED
windowing_strategy_id: "WindowingStrategy(GlobalWindows)"
}] were consumed but never produced
at
org.apache.beam.repackaged.beam_runners_core_construction_java.com.google.common.base.Preconditions.checkArgument(Preconditions.java:383)
at
org.apache.beam.runners.core.construction.graph.QueryablePipeline.buildNetwork(QueryablePipeline.java:183)
at
org.apache.beam.runners.core.construction.graph.QueryablePipeline.<init>(QueryablePipeline.java:106)
at
org.apache.beam.runners.core.construction.graph.QueryablePipeline.forPrimitivesIn(QueryablePipeline.java:69)
at
org.apache.beam.runners.core.construction.graph.GreedyPipelineFuser.<init>(GreedyPipelineFuser.java:67)
at
org.apache.beam.runners.core.construction.graph.GreedyPipelineFuser.fuse(GreedyPipelineFuser.java:89)
at
org.apache.beam.runners.direct.portable.ReferenceRunner.executable(ReferenceRunner.java:128)
at
org.apache.beam.runners.direct.portable.ReferenceRunner.<init>(ReferenceRunner.java:102)
at
org.apache.beam.runners.direct.portable.ReferenceRunner.forInProcessPipeline(ReferenceRunner.java:114)
at
org.apache.beam.runners.direct.portable.ReferenceRunnerTest.testSDF(ReferenceRunnerTest.java:207)
```
[ Full content available at: https://github.com/apache/beam/pull/6328 ]
This message was relayed via gitbox.apache.org for [email protected]
