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

NIFI-9736 Improved TestRouteText to avoid intermittent failures (#5814) 

- Refactored testPatternCache to avoid testing maximum cache size reached
This commit is contained in:
exceptionfactory 2022-02-28 14:26:19 -05:00 committed by GitHub
parent 649e2d2556
commit ddecfa201b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestRouteText.java
View File

@ -769,29 +769,28 @@ public class TestRouteText {
final RouteText routeText = new RouteText();
final TestRunner runner = TestRunners.newTestRunner(routeText);
runner.setProperty(RouteText.MATCH_STRATEGY, RouteText.MATCHES_REGULAR_EXPRESSION);
runner.setProperty("simple", ".*(${someValue}).*");
final String simpleRelationship = "simple";
runner.setProperty(simpleRelationship, ".*(${someValue}).*");
final int iterations = 2;
runner.enqueue("some text", Collections.singletonMap("someValue", "a value"));
runner.enqueue("some other text", Collections.singletonMap("someValue", "a value"));
runner.run(2);
runner.run(iterations);
assertEquals("Expected 1 elements in the cache for the patterns, got" +
routeText.patternsCache.size(), 1, routeText.patternsCache.size());
assertEquals(1, routeText.patternsCache.size());
for (int i = 0; i < RouteText.PATTERNS_CACHE_MAXIMUM_ENTRIES * 2; ++i) {
for (int i = 0; i < iterations; ++i) {
String iString = Long.toString(i);
runner.enqueue("some text with " + iString + "in it",
Collections.singletonMap("someValue", iString));
runner.run();
}
assertEquals("Expected " + RouteText.PATTERNS_CACHE_MAXIMUM_ENTRIES +
" elements in the cache for the patterns, got" + routeText.patternsCache.size(),
RouteText.PATTERNS_CACHE_MAXIMUM_ENTRIES, routeText.patternsCache.size());
runner.assertTransferCount("simple", RouteText.PATTERNS_CACHE_MAXIMUM_ENTRIES * 2);
runner.assertTransferCount("unmatched", 2);
runner.assertTransferCount("original", RouteText.PATTERNS_CACHE_MAXIMUM_ENTRIES * 2 + 2);
runner.assertTransferCount(simpleRelationship, iterations);
runner.assertTransferCount(RouteText.REL_MATCH, 0);
runner.assertTransferCount(RouteText.REL_NO_MATCH, iterations);
runner.assertTransferCount(RouteText.REL_ORIGINAL, iterations * 2);
runner.setProperty(RouteText.IGNORE_CASE, "true");
assertEquals("Pattern cache is not cleared after changing IGNORE_CASE", 0, routeText.patternsCache.size());