Skip to content

Commit 362a17f

Browse files
authored
Merge pull request #31 from civitaspo/trimDoubleByteSpace
Trim Double-byte space
2 parents a771a8b + b65cd4c commit 362a17f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/org/embulk/input/hdfs/TargetFileInputStreamFactory.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -75,11 +75,11 @@ private InputStream createDecompressedInputStream(TargetFileInfo t)
7575
CompressionCodecFactory factory = new CompressionCodecFactory(fs.getConf());
7676
CompressionCodec codec = factory.getCodec(new Path(t.getPathString()));
7777
if (codec == null) {
78-
logger.debug("embulk-input-hdfs: CompressionCodec: null: {}", t.getPathString());
78+
logger.debug("embulk-input-hdfs: CompressionCodec: null: {}", t.getPathString());
7979
return original;
8080
}
8181
else {
82-
logger.debug("embulk-input-hdfs: CompressionCodec: {}: {}", codec, t.getPathString());
82+
logger.debug("embulk-input-hdfs: CompressionCodec: {}: {}", codec, t.getPathString());
8383
return codec.createInputStream(original);
8484
}
8585
}

0 commit comments

Comments
 (0)