Skip to content

Commit

Permalink
Revert BigQueryIO bit of 'Make all uses of CountingOutputStream close…
Browse files Browse the repository at this point in the history
… their resources'

This reverts the portion of commit 3115dbd
that touches BigQueryIO, which caused a double close bug.
  • Loading branch information
kennknowles committed Mar 11, 2017
1 parent 7c78480 commit 598c24e
Showing 1 changed file with 1 addition and 3 deletions.
Expand Up @@ -2272,9 +2272,7 @@ public void write(TableRow value) throws Exception {

public final KV<String, Long> close() throws IOException {
channel.close();
KV<String, Long> record = KV.of(fileName, out.getCount());
out.close();
return record;
return KV.of(fileName, out.getCount());
}
}

Expand Down

0 comments on commit 598c24e

Please sign in to comment.