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

Try fixing coder issue

parent 08042e24
No related branches found
No related tags found
No related merge requests found
Pipeline #7287 passed
...@@ -103,7 +103,8 @@ public class SimplePipelineFactory extends AbstractPipelineFactory { ...@@ -103,7 +103,8 @@ public class SimplePipelineFactory extends AbstractPipelineFactory {
protected void registerCoders(final CoderRegistry registry) { protected void registerCoders(final CoderRegistry registry) {
registry.registerCoderForClass( registry.registerCoderForClass(
ActivePowerRecord.class, ActivePowerRecord.class,
AvroCoder.of(ActivePowerRecord.SCHEMA$)); // AvroCoder.of(ActivePowerRecord.SCHEMA$));
AvroCoder.of(ActivePowerRecord.class, false));
registry.registerCoderForClass( registry.registerCoderForClass(
HourOfDayKey.class, HourOfDayKey.class,
new HourOfDayKeyCoder()); new HourOfDayKeyCoder());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment