diff --git a/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/SimplePipelineFactory.java b/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/SimplePipelineFactory.java index b2783fe4ed92f945bc023adf50b3ce20bb3436d3..e4d3c7a08aa035fac1fac638f36524e165faa4ff 100644 --- a/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/SimplePipelineFactory.java +++ b/theodolite-benchmarks/uc3-beam/src/main/java/rocks/theodolite/benchmarks/uc3/beam/SimplePipelineFactory.java @@ -103,7 +103,8 @@ public class SimplePipelineFactory extends AbstractPipelineFactory { protected void registerCoders(final CoderRegistry registry) { registry.registerCoderForClass( ActivePowerRecord.class, - AvroCoder.of(ActivePowerRecord.SCHEMA$)); + // AvroCoder.of(ActivePowerRecord.SCHEMA$)); + AvroCoder.of(ActivePowerRecord.class, false)); registry.registerCoderForClass( HourOfDayKey.class, new HourOfDayKeyCoder());