nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbe...@apache.org
Subject nifi git commit: NIFI-3789 Removing unnecessary intermittent test failure as described in JIRA
Date Wed, 03 May 2017 18:09:47 GMT
Repository: nifi
Updated Branches:
  refs/heads/master 9b177fbcb -> 1e75f3367


NIFI-3789 Removing unnecessary intermittent test failure as described in JIRA

This closes #1743.


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1e75f336
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1e75f336
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1e75f336

Branch: refs/heads/master
Commit: 1e75f33677b47900a402e772901d80a7076c34fe
Parents: 9b177fb
Author: Bryan Bende <bbende@apache.org>
Authored: Wed May 3 14:02:37 2017 -0400
Committer: Bryan Bende <bbende@apache.org>
Committed: Wed May 3 14:07:18 2017 -0400

----------------------------------------------------------------------
 ...tedWriteAheadProvenanceRepositoryTest.groovy | 45 --------------------
 1 file changed, 45 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/1e75f336/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 42cc881..7cc4919 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
@@ -201,51 +201,6 @@ class EncryptedWriteAheadProvenanceRepositoryTest {
     }
 
     /**
-     * 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<ProvenanceEventRecord> 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.
      *
      * @throws IOException


Mime
View raw message