From 1e75f33677b47900a402e772901d80a7076c34fe Mon Sep 17 00:00:00 2001 From: Bryan Bende Date: Wed, 3 May 2017 14:02:37 -0400 Subject: [PATCH] NIFI-3789 Removing unnecessary intermittent test failure as described in JIRA This closes #1743. --- ...dWriteAheadProvenanceRepositoryTest.groovy | 45 ------------------- 1 file changed, 45 deletions(-) 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 42cc8819be..7cc4919f3d 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 @@ -200,51 +200,6 @@ class EncryptedWriteAheadProvenanceRepositoryTest { builder.build() } - /** - * This test operates on {@link PersistentProvenanceRepository} to verify the normal operations of existing implementations. - * - * @throws IOException - * @throws InterruptedException - */ - @Test - void testPersistentProvenanceRepositoryShouldRegisterAndRetrieveEvents() throws IOException, InterruptedException { - // Arrange - config = createConfiguration() - config.setMaxEventFileCapacity(1L) - config.setMaxEventFileLife(1, TimeUnit.SECONDS) - repo = new PersistentProvenanceRepository(config, DEFAULT_ROLLOVER_MILLIS) - repo.initialize(eventReporter, null, null, IdentifierLookup.EMPTY) - - Map attributes = ["abc": "xyz", - "123": "456"] - final ProvenanceEventRecord record = buildEventRecord(buildFlowFile(attributes)) - - final int RECORD_COUNT = 10 - - // Act - RECORD_COUNT.times { - repo.registerEvent(record) - } - - // Sleep to let the journal merge occur - Thread.sleep(1000L) - - final List recoveredRecords = repo.getEvents(0L, RECORD_COUNT + 1) - - logger.info("Recovered ${recoveredRecords.size()} events: ") - recoveredRecords.each { logger.info("\t${it}") } - - // Assert - assert recoveredRecords.size() == RECORD_COUNT - recoveredRecords.eachWithIndex { ProvenanceEventRecord recovered, int i -> - assert recovered.getEventId() == (i as Long) - assert recovered.getTransitUri() == TRANSIT_URI - assert recovered.getEventType() == ProvenanceEventType.RECEIVE - // The UUID was added later but we care that all attributes we provided are still there - assert recovered.getAttributes().entrySet().containsAll(attributes.entrySet()) - } - } - /** * This test operates on {@link WriteAheadProvenanceRepository} to verify the normal operations of existing implementations. *