Fix ParquetLoad coder issue

Author: qqndrew

API/pom.xml

@@ -31,7 +31,7 @@
     <parent>
         <groupId>org.ohnlp.backbone</groupId>
         <artifactId>backbone-parent</artifactId>
-        <version>3.0.28</version>
+        <version>3.0.29</version>
     </parent>
 
     <artifactId>api</artifactId>

Core/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.ohnlp.backbone</groupId>
         <artifactId>backbone-parent</artifactId>
-        <version>3.0.28</version>
+        <version>3.0.29</version>
     </parent>
 
     <artifactId>core</artifactId>

Example-Backbone-Configs/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.ohnlp.backbone</groupId>
         <artifactId>backbone-parent</artifactId>
-        <version>3.0.28</version>
+        <version>3.0.29</version>
     </parent>
 
     <artifactId>example-backbone-configs</artifactId>

IO/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.ohnlp.backbone</groupId>
         <artifactId>backbone-parent</artifactId>
-        <version>3.0.28</version>
+        <version>3.0.29</version>
     </parent>
 
     <groupId>org.ohnlp.backbone.io</groupId>

IO/src/main/java/org/ohnlp/backbone/io/local/ParquetLoad.java

@@ -1,6 +1,7 @@
 package org.ohnlp.backbone.io.local;
 
 import org.apache.avro.generic.GenericRecord;
+import org.apache.beam.sdk.coders.AvroCoder;
 import org.apache.beam.sdk.io.FileIO;
 import org.apache.beam.sdk.io.parquet.ParquetIO;
 import org.apache.beam.sdk.schemas.Schema;
@@ -65,6 +66,7 @@ public void processElement(@Element Row input, OutputReceiver<GenericRecord> out
                         output.output(AvroUtils.toGenericRecord(input, AvroUtils.toAvroSchema(beamSchema)));
                     }
                 }))
+                .setCoder(AvroCoder.of(GenericRecord.class, AvroUtils.toAvroSchema(beamSchema)))
                 .apply("Write to Filesystem", FileIO
                         .<GenericRecord>write()
                         .via(ParquetIO.sink(AvroUtils.toAvroSchema(beamSchema)))

Plugin-Manager/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.ohnlp.backbone</groupId>
         <artifactId>backbone-parent</artifactId>
-        <version>3.0.28</version>
+        <version>3.0.29</version>
     </parent>
 
     <artifactId>plugin-manager</artifactId>

Transforms/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>org.ohnlp.backbone</groupId>
         <artifactId>backbone-parent</artifactId>
-        <version>3.0.28</version>
+        <version>3.0.29</version>
     </parent>
 
     <groupId>org.ohnlp.backbone.transforms</groupId>

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>org.ohnlp.backbone</groupId>
     <artifactId>backbone-parent</artifactId>
-    <version>3.0.28</version>
+    <version>3.0.29</version>
 
 
     <properties>