Repository: nifi Updated Branches: refs/heads/master 7c27d4c58 -> ff65b42e8
NIFI-4110 Added Thread.sleep() to ensure provenance event indexing occurs before retrieval and unit test passes. Signed-off-by: Scott Aslan <[email protected]> This closes #1935 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ff65b42e Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ff65b42e Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ff65b42e Branch: refs/heads/master Commit: ff65b42e88dbea823877ac58e72b4b126ccb20c1 Parents: 7c27d4c Author: Andy LoPresto <[email protected]> Authored: Thu Jun 22 16:19:06 2017 -0400 Committer: Scott Aslan <[email protected]> Committed: Fri Jun 23 08:48:34 2017 -0400 ---------------------------------------------------------------------- .../provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/ff65b42e/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/groovy/org/apache/nifi/provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/groovy/org/apache/nifi/provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/groovy/org/apache/nifi/provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy index 7cc4919..01c4982 100644 --- a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/groovy/org/apache/nifi/provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy +++ b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/groovy/org/apache/nifi/provenance/EncryptedWriteAheadProvenanceRepositoryTest.groovy @@ -228,6 +228,9 @@ class EncryptedWriteAheadProvenanceRepositoryTest { 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) logger.info("Recovered ${recoveredRecords.size()} events: ")
