fix findbug warnings
Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/16b88aeb Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/16b88aeb Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/16b88aeb Branch: refs/heads/index_support Commit: 16b88aeb542fb4376b970bb1707b17502ccd6c53 Parents: e2884b2 Author: Jinho Kim <[email protected]> Authored: Wed Apr 1 14:37:18 2015 +0900 Committer: Jinho Kim <[email protected]> Committed: Wed Apr 1 14:37:18 2015 +0900 ---------------------------------------------------------------------- .../src/main/java/org/apache/tajo/storage/FileAppender.java | 4 ++++ .../org/apache/tajo/storage/thirdparty/parquet/CodecFactory.java | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/16b88aeb/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileAppender.java ---------------------------------------------------------------------- diff --git a/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileAppender.java b/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileAppender.java index b208a71..ac14e63 100644 --- a/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileAppender.java +++ b/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/FileAppender.java @@ -53,6 +53,10 @@ public abstract class FileAppender implements Appender { try { if (taskAttemptId != null) { + if (!(conf instanceof TajoConf)) { + throw new IllegalArgumentException("Configuration must be a TajoConf instance"); + } + this.path = ((FileStorageManager)StorageManager.getFileStorageManager((TajoConf) conf)) .getAppenderFilePath(taskAttemptId, workDir); } else { http://git-wip-us.apache.org/repos/asf/tajo/blob/16b88aeb/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/thirdparty/parquet/CodecFactory.java ---------------------------------------------------------------------- diff --git a/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/thirdparty/parquet/CodecFactory.java b/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/thirdparty/parquet/CodecFactory.java index f76593e..4ba47c1 100644 --- a/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/thirdparty/parquet/CodecFactory.java +++ b/tajo-storage/tajo-storage-hdfs/src/main/java/org/apache/tajo/storage/thirdparty/parquet/CodecFactory.java @@ -34,7 +34,7 @@ import java.util.Map; class CodecFactory { - public class BytesDecompressor { + public static class BytesDecompressor { private final CompressionCodec codec; private final Decompressor decompressor;
