NIFI-713: Fixed checkstyle issue
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/f884086f Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/f884086f Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/f884086f Branch: refs/heads/master Commit: f884086fc2085cc0dbf5e1a80bca4a6a5138e42a Parents: da56b49 Author: Mark Payne <[email protected]> Authored: Wed Sep 23 15:20:25 2015 -0400 Committer: Mark Payne <[email protected]> Committed: Wed Sep 23 15:20:25 2015 -0400 ---------------------------------------------------------------------- .../apache/nifi/processors/hadoop/CreateHadoopSequenceFile.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/f884086f/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/CreateHadoopSequenceFile.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/CreateHadoopSequenceFile.java b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/CreateHadoopSequenceFile.java index 1f55164..cbcc54d 100644 --- a/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/CreateHadoopSequenceFile.java +++ b/nifi-nar-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/CreateHadoopSequenceFile.java @@ -153,8 +153,8 @@ public class CreateHadoopSequenceFile extends AbstractHadoopProcessor { sequenceFileWriter = new SequenceFileWriterImpl(); } String value = context.getProperty(COMPRESSION_TYPE).getValue(); - SequenceFile.CompressionType compressionType = value == null ? - SequenceFile.CompressionType.valueOf(DEFAULT_COMPRESSION_TYPE) : SequenceFile.CompressionType.valueOf(value); + SequenceFile.CompressionType compressionType = value == null + ? SequenceFile.CompressionType.valueOf(DEFAULT_COMPRESSION_TYPE) : SequenceFile.CompressionType.valueOf(value); final String fileName = flowFile.getAttribute(CoreAttributes.FILENAME.key()) + ".sf"; flowFile = session.putAttribute(flowFile, CoreAttributes.FILENAME.key(), fileName); try {
