[
https://issues.apache.org/jira/browse/NIFI-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406546#comment-15406546
]
ASF GitHub Bot commented on NIFI-2407:
--------------------------------------
Github user markap14 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/778#discussion_r73411049
--- Diff:
nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/PutHDFSTest.java
---
@@ -199,7 +202,39 @@ public void testPutFile() throws IOException {
TestRunner runner = TestRunners.newTestRunner(proc);
runner.setProperty(PutHDFS.DIRECTORY, "target/test-classes");
runner.setProperty(PutHDFS.CONFLICT_RESOLUTION, "replace");
- runner.setValidateExpressionUsage(false);
+ try (FileInputStream fis = new
FileInputStream("src/test/resources/testdata/randombytes-1");) {
+ Map<String, String> attributes = new HashMap<String, String>();
+ attributes.put(CoreAttributes.FILENAME.key(), "randombytes-1");
+ runner.enqueue(fis, attributes);
+ runner.run();
+ }
+
+ Configuration config = new Configuration();
+ FileSystem fs = FileSystem.get(config);
+
+ List<MockFlowFile> failedFlowFiles = runner
+ .getFlowFilesForRelationship(new
Relationship.Builder().name("failure").build());
+ assertTrue(failedFlowFiles.isEmpty());
+
+ List<MockFlowFile> flowFiles =
runner.getFlowFilesForRelationship(PutHDFS.REL_SUCCESS);
+ assertEquals(1, flowFiles.size());
--- End diff --
The above assertion that failed flowfiles is empty and that this has size 1
can be simplified to simply using:
runner.assertAllFlowFilesTransferred(PutHDFS.REL_SUCCESS, 1);
> Add EL support to processors/controller services
> ------------------------------------------------
>
> Key: NIFI-2407
> URL: https://issues.apache.org/jira/browse/NIFI-2407
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Reporter: Jeff Storck
> Assignee: Jeff Storck
> Fix For: 1.0.0
>
>
> Add support for EL:
> * "Directory" property for GetHDFS and ListHDFS processors
> * "Destination Name" property for ConsumeJMS and PublishJMS processors
> * "MQ ConnectionFactory Implementation", "MQ client library path", "Broker
> URI" properties for the JMS Connection Factory Provider
> * "Database Connection URL", "Database Driver Class Name", "DB Driver jar
> url", "DB username", and "DB password" properties for the DBCP Connection Pool
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
