Repository: nifi Updated Branches: refs/heads/master 1ea49ad8c -> bc6b22389
NIFI-2407: Fixed NPE Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/bc6b2238 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/bc6b2238 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/bc6b2238 Branch: refs/heads/master Commit: bc6b22389b94b95fe3bae79a141e20d007c58ea5 Parents: 1ea49ad Author: Mark Payne <[email protected]> Authored: Thu Aug 4 14:50:30 2016 -0400 Committer: Mark Payne <[email protected]> Committed: Thu Aug 4 14:50:30 2016 -0400 ---------------------------------------------------------------------- .../apache/nifi/processors/hadoop/GetHDFSSequenceFileTest.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/bc6b2238/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/GetHDFSSequenceFileTest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/GetHDFSSequenceFileTest.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/GetHDFSSequenceFileTest.java index 2ae99f0..33bd135 100644 --- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/GetHDFSSequenceFileTest.java +++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/test/java/org/apache/nifi/processors/hadoop/GetHDFSSequenceFileTest.java @@ -26,6 +26,7 @@ import org.apache.nifi.hadoop.KerberosProperties; import org.apache.nifi.processor.ProcessContext; import org.apache.nifi.processor.ProcessorInitializationContext; import org.apache.nifi.processors.hadoop.util.SequenceFileReader; +import org.apache.nifi.util.MockProcessContext; import org.junit.Before; import org.junit.Test; import org.mockito.ArgumentCaptor; @@ -63,10 +64,7 @@ public class GetHDFSSequenceFileTest { } private void init() throws IOException { - ProcessContext context = mock(ProcessContext.class); - when(context.getProperty(AbstractHadoopProcessor.KERBEROS_RELOGIN_PERIOD)).thenReturn(mock(PropertyValue.class)); - when(context.getProperty(AbstractHadoopProcessor.HADOOP_CONFIGURATION_RESOURCES)).thenReturn(mock(PropertyValue.class)); - when(context.getProperty(AbstractHadoopProcessor.DIRECTORY_PROP_NAME)).thenReturn(mock(PropertyValue.class)); + final MockProcessContext context = new MockProcessContext(getHDFSSequenceFile); getHDFSSequenceFile.init(mock(ProcessorInitializationContext.class)); getHDFSSequenceFile.onScheduled(context); }
