diff --git a/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/AbstractPipelineFactory.java b/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/AbstractPipelineFactory.java index 8bf913fc2f7a8d1f18aed63185a014fe43bcab44..4976f46e231c472599f85a72f698e26a09cbc860 100644 --- a/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/AbstractPipelineFactory.java +++ b/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/AbstractPipelineFactory.java @@ -30,8 +30,8 @@ public abstract class AbstractPipelineFactory { public final Pipeline create(final PipelineOptions options) { this.expandOptions(options); final Pipeline pipeline = Pipeline.create(options); - this.constructPipeline(pipeline); this.registerCoders(pipeline.getCoderRegistry()); + this.constructPipeline(pipeline); return pipeline; }