Update

tspannhw · Dec 21, 2016 · 7914833 · 7914833
1 parent f1e75b6
commit 7914833
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/...cess-processors/src/main/java/com/dataflowdeveloper/processors/process/LinkProcessor.java b/...cess-processors/src/main/java/com/dataflowdeveloper/processors/process/LinkProcessor.java
@@ -141,7 +141,7 @@ public void onTrigger(final ProcessContext context, final ProcessSession session
 
 		try {
 			//Output Flowfile			
-			flowFile = session.putAttribute(flowFile, ATTRIBUTE_OUTPUT_NAME, outputJSON);
+			//flowFile = session.putAttribute(flowFile, ATTRIBUTE_OUTPUT_NAME, outputJSON);
 
 			flowFile = session.write(flowFile, new OutputStreamCallback() {
 				@Override

diff --git a/...-processors/src/test/java/com/dataflowdeveloper/processors/process/LinkProcessorTest.java b/...-processors/src/test/java/com/dataflowdeveloper/processors/process/LinkProcessorTest.java
@@ -22,7 +22,6 @@
 import java.io.UnsupportedEncodingException;
 import java.util.List;
 
-import org.apache.nifi.provenance.ProvenanceEventRecord;
 import org.apache.nifi.util.MockFlowFile;
 import org.apache.nifi.util.TestRunner;
 import org.apache.nifi.util.TestRunners;
@@ -51,14 +50,14 @@ public void testProcessor() {
 		testRunner.assertValid();
 		List<MockFlowFile> successFiles = testRunner.getFlowFilesForRelationship(LinkProcessor.REL_SUCCESS);
 
-		for (ProvenanceEventRecord events : testRunner.getProvenanceEvents()) {
-			System.out.println("Output: " + events.getAttributes().get(LinkProcessor.ATTRIBUTE_OUTPUT_NAME));
-		}
+//		for (ProvenanceEventRecord events : testRunner.getProvenanceEvents()) {
+//			System.out.println("Output: " + events.getAttributes().get(LinkProcessor.ATTRIBUTE_OUTPUT_NAME));
+//		}
 
 		for (MockFlowFile mockFile : successFiles) {
 			try {
 				System.out.println("FILE:" + new String(mockFile.toByteArray(), "UTF-8"));
-				System.out.println("Attribute: " + mockFile.getAttribute(LinkProcessor.ATTRIBUTE_OUTPUT_NAME));
+				//System.out.println("Attribute: " + mockFile.getAttribute(LinkProcessor.ATTRIBUTE_OUTPUT_NAME));
 
 			} catch (UnsupportedEncodingException e) {
 				e.printStackTrace();