better reporting for a bad schema

spullara · Jun 5, 2011 · a7039d6 · a7039d6
1 parent 244b4de
commit a7039d6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/file/src/main/java/avrobase/file/FAB.java b/file/src/main/java/avrobase/file/FAB.java
@@ -155,7 +155,11 @@ private Row<T, K> _get(K row) throws IOException {
       Schema schema = schemaCache.get(hash);
       if (schema == null) {
         File schemaFile = new File(schemaDir, hash);
-        schema = Schema.parse(new FileInputStream(schemaFile));
+        try {
+          schema = Schema.parse(new FileInputStream(schemaFile));
+        } catch (IOException ioe) {
+          throw new AvroBaseException("Failed to read schema for hash: " + hash + " row: " + row, ioe);
+        }
         schemaCache.put(hash, schema);
         hashCache.put(schema, hash);
       }