Fix test TestHoodieReaderWriterBase

apache · Apr 25, 2022 · 39f75ef · 39f75ef
1 parent b8529d9
commit 39f75ef
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...di-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieReaderWriterBase.java b/...di-client-common/src/test/java/org/apache/hudi/io/storage/TestHoodieReaderWriterBase.java
@@ -19,6 +19,7 @@
 
 package org.apache.hudi.io.storage;
 
+import org.apache.avro.AvroRuntimeException;
 import org.apache.hudi.common.bloom.BloomFilter;
 
 import org.apache.avro.Schema;
@@ -46,6 +47,7 @@
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
 /**
@@ -246,6 +248,7 @@ private void verifyRecord(String schemaPath, GenericRecord record, int index) {
     } else {
       assertEquals(index, record.get("number"));
     }
-    assertNull(record.get("added_field"));
+    GenericRecord finalRec = record;
+    assertThrows(AvroRuntimeException.class, () -> finalRec.get("added_field"));
   }
 }