fix

Author: tianchen92

java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java

@@ -246,8 +246,13 @@ public static VectorSchemaRoot avroToArrowVectors(Schema schema, Decoder decoder
 
     VectorSchemaRoot root = new VectorSchemaRoot(fields, vectors, 0);
 
-    try (CompositeAvroConsumer compositeConsumer = new CompositeAvroConsumer(consumers)) {
+    CompositeAvroConsumer compositeConsumer = null;
+    try {
+      compositeConsumer = new CompositeAvroConsumer(consumers);
       compositeConsumer.consume(decoder, root);
+    } catch (Exception e) {
+      compositeConsumer.close();
+      throw new RuntimeException("Error occurs while consume process.", e);
     }
 
     return root;

java/adapter/avro/src/main/java/org/apache/arrow/consumers/Consumer.java

@@ -50,7 +50,7 @@ public interface Consumer extends AutoCloseable {
   FieldVector getVector();
 
   /**
-   * Close this consumer, do some clean work such as clear vectors.
+   * Close this consumer when occurs exception to avoid potential leak.
    */
   void close() throws Exception;
 }