Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-3084 Fixing TestPersistentProvenanceRepository and closing a stream leak in RecordReaders. 

This closes #1260.
This commit is contained in:
Joseph Percivall 2016-11-22 17:11:13 -05:00 committed by Mark Payne
parent 913ae91614
commit 50667ed222
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/serialization/RecordReaders.java
View File

@ -118,6 +118,7 @@ public class RecordReaders {
serializationName = dis.readUTF(); serializationName = dis.readUTF();
bufferedInStream.reset(); bufferedInStream.reset();
} catch (final EOFException eof) { } catch (final EOFException eof) {
fis.close();
return new EmptyRecordReader(); return new EmptyRecordReader();
} }

2
nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java
View File

@ -1585,6 +1585,8 @@ public class TestPersistentProvenanceRepository {
builder.fromFlowFile(createFlowFile(15, 3000L, attributes)); builder.fromFlowFile(createFlowFile(15, 3000L, attributes));
attributes.put("uuid", "00000000-0000-0000-0000-00000000000" + 15); attributes.put("uuid", "00000000-0000-0000-0000-00000000000" + 15);
repo.registerEvent(builder.build()); repo.registerEvent(builder.build());
Thread.sleep(3000L);
} }