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

NIFI-4110 Added Thread.sleep() to ensure provenance event indexing occurs before retrieval and unit test passes. 

Signed-off-by: Scott Aslan <scottyaslan@gmail.com>

This closes #1935
This commit is contained in:
Andy LoPresto 2017-06-22 16:19:06 -04:00 committed by Scott Aslan
parent 7c27d4c588
commit ff65b42e88
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/groovy/org/apache/nifi/provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy
View File

@ -228,6 +228,9 @@ class EncryptedWriteAheadProvenanceRepositoryTest {
repo.registerEvent(record) repo.registerEvent(record)
} }
// Ensure there is not a timing issue retrieving all records
Thread.sleep(1000)
final List<ProvenanceEventRecord> recoveredRecords = repo.getEvents(0L, RECORD_COUNT + 1) final List<ProvenanceEventRecord> recoveredRecords = repo.getEvents(0L, RECORD_COUNT + 1)
logger.info("Recovered ${recoveredRecords.size()} events: ") logger.info("Recovered ${recoveredRecords.size()} events: ")