embulk-standards/src/main/java/org/embulk/standards/StdoutOutputPlugin.java in embulk-0.5.1 vs embulk-standards/src/main/java/org/embulk/standards/StdoutOutputPlugin.java in embulk-0.5.2
- old
+ new
@@ -62,18 +62,20 @@
{
reader.setPage(page);
while (reader.nextRecord()) {
System.out.println(printer.printRecord(reader, ","));
}
- page.release();
}
public void finish()
{
System.out.flush();
}
- public void close() { }
+ public void close()
+ {
+ reader.close();
+ }
public void abort() { }
public CommitReport commit()
{