destruct schema reader when finish reading

This commit is contained in:
Yurui Zhou committed 2019-06-06 15:12:01 +08:00
1 parent 4f89e34541
commit f2a0c04b88
1 file changed
+3 -5
@@ -88,11 +88,7 @@ public class OrcStripeReader extends ArrowReader {
@Override
protected void closeReadSource() throws IOException {
try {
OrcStripeReaderJniWrapper.close(id);
} finally {
schemaReader.close();
}
OrcStripeReaderJniWrapper.close(id);
}
@Override
@@ -112,6 +108,8 @@ public class OrcStripeReader extends ArrowReader {
throw new IOException("Expected schema but header was " + result.getMessage().headerType());
}
schemaReader.close();
return MessageSerializer.deserializeSchema(result.getMessage());
}