diff --git a/java/src/org/broadinstitute/sting/gatk/walkers/indels/IndelRealigner.java b/java/src/org/broadinstitute/sting/gatk/walkers/indels/IndelRealigner.java index c0576cbe0..85e916aea 100755 --- a/java/src/org/broadinstitute/sting/gatk/walkers/indels/IndelRealigner.java +++ b/java/src/org/broadinstitute/sting/gatk/walkers/indels/IndelRealigner.java @@ -291,14 +291,11 @@ public class IndelRealigner extends ReadWalker { } if ( writers != null ) { - for ( SAMFileWriter writer : writers.values() ) { - // TODO -- figure out why we're getting an exception thrown here - // TODO -- because we need to call close() to flush out the remaining reads from the writer - try { - writer.close(); - if ( !SORT_ON_DISK ) - ((SortingSAMFileWriter)writer).getBaseWriter().close(); - } catch (RuntimeException e) {} + HashSet uniqueWriters = new HashSet(writers.values()); + for ( SAMFileWriter writer : uniqueWriters ) { + writer.close(); + if ( !SORT_ON_DISK ) + ((SortingSAMFileWriter)writer).getBaseWriter().close(); } }