Skip to content
Snippets Groups Projects
Commit 25155d6c authored by Sören Henning's avatar Sören Henning
Browse files

Register coders before creating pipeline

parent 654ff9ae
No related branches found
No related tags found
1 merge request!249Align package structure among all benchmark implementations
Pipeline #6791 canceled
......@@ -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;
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment