From 25155d6c524d67a6974d50f6813905686adbfd03 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de> Date: Fri, 25 Feb 2022 16:56:56 +0100 Subject: [PATCH] Register coders before creating pipeline --- .../benchmarks/commons/beam/AbstractPipelineFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 8bf913fc2..4976f46e2 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; } -- GitLab