Rest of BRecord changes for tests to pass

epiphanous · Dec 28, 2022 · d2eccc9 · d2eccc9
1 parent 132ae86
commit d2eccc9
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/src/test/avro/BRecord.avsc b/src/test/avro/BRecord.avsc
@@ -6,6 +6,7 @@
     { "name": "b0", "type": "string" },
     { "name": "b1", "type": ["null", "int"] },
     { "name": "b2", "type": ["null", "double"] },
-    { "name": "b3", "type": {"type": "long", "logicalType": "timestamp-millis" }}
+    { "name": "b3", "type": {"type": "long", "logicalType": "timestamp-millis" }},
+    { "name": "b4", "type": "string" }
   ]
 }
diff --git a/src/test/scala/io/epiphanous/flinkrunner/serde/DelimitedRowEncoderTest.scala b/src/test/scala/io/epiphanous/flinkrunner/serde/DelimitedRowEncoderTest.scala
@@ -30,7 +30,7 @@ class DelimitedRowEncoderTest
 
   property("encode non-nested avro property") {
     def csvLine(b: BRecord): String =
-      s"${b.b0},${b.b1.getOrElse("")},${b.b2.getOrElse("")},${b.b3.toEpochMilli}${System.lineSeparator()}"
+      s"${b.b0},${b.b1.getOrElse("")},${b.b2.getOrElse("")},${b.b3.toEpochMilli},${b.b4}${System.lineSeparator()}"
     val encoder                     = getTypedRowEncoder[BRecord]()
     forAll { test: BRecord =>
       encoder

diff --git a/src/test/scala/io/epiphanous/flinkrunner/util/AvroUtilsTest.scala b/src/test/scala/io/epiphanous/flinkrunner/util/AvroUtilsTest.scala
@@ -16,6 +16,7 @@ class AvroUtilsTest extends PropSpec {
       .set("b1", spec.b1.getOrElse(null)) // orNull won't work here
       .set("b2", spec.b2.getOrElse(null)) // orNull won't work here
       .set("b3", spec.b3.toEpochMilli)
+      .set("b4", spec.b4)
       .build()
 
   def fromSpecCRecord(spec: CRecord): GenericRecord =