From b5cce95ead1c5344c9cb207bcb747f7f28a7bad2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Mon, 28 Mar 2022 16:37:44 +0200
Subject: [PATCH] Try fixing coder issue
---
.../theodolite/benchmarks/uc3/beam/SimplePipelineFactory.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 b2783fe4e..e4d3c7a08 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());
--
GitLab