avro_ocf: Fix panic on missing meta schema

wader · Jul 23, 2022 · 5d67df4 · 5d67df4
1 parent 8b5cc89
commit 5d67df4
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/format/avro/avro_ocf.go b/format/avro/avro_ocf.go
@@ -70,7 +70,12 @@ func decodeHeader(d *decode.D) HeaderData {
 		d.Fatalf("header.meta is not a map")
 	}
 
-	headerData.Schema, err = schema.FromSchemaString(meta["avro.schema"].(string))
+	metaSchema, ok := meta["avro.schema"].(string)
+	if !ok {
+		d.Fatalf("missing meta avro.schema")
+	}
+
+	headerData.Schema, err = schema.FromSchemaString(metaSchema)
 	if err != nil {
 		d.Fatalf("failed to parse schema: %v", err)
 	}