camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject [4/6] git commit: CAMEL-7900 Honored chunksize in camel-hdfs
Date Sat, 11 Oct 2014 05:58:16 GMT
CAMEL-7900 Honored chunksize in camel-hdfs


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/607ab4e8
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/607ab4e8
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/607ab4e8

Branch: refs/heads/camel-2.13.x
Commit: 607ab4e83cb4af96b88d90a62bfdd1b609c53ce0
Parents: 4ff0ee9
Author: Willem Jiang <willem.jiang@gmail.com>
Authored: Fri Oct 10 21:58:47 2014 +0800
Committer: Willem Jiang <willem.jiang@gmail.com>
Committed: Sat Oct 11 13:57:24 2014 +0800

----------------------------------------------------------------------
 .../main/java/org/apache/camel/component/hdfs/HdfsFileType.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/607ab4e8/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsFileType.java
----------------------------------------------------------------------
diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsFileType.java
b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsFileType.java
index a3b2112..97c174f 100644
--- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsFileType.java
+++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsFileType.java
@@ -75,7 +75,7 @@ public enum HdfsFileType {
         public long next(HdfsInputStream hdfsistr, Holder<Object> key, Holder<Object>
value) {
             try {
                 ByteArrayOutputStream bos = new ByteArrayOutputStream(hdfsistr.getChunkSize());
-                byte buf[] = new byte[HdfsConstants.DEFAULT_BUFFERSIZE];
+                byte buf[] = new byte[hdfsistr.getChunkSize()];
                 int bytesRead = ((InputStream) hdfsistr.getIn()).read(buf);
                 if (bytesRead >= 0) {
                     bos.write(buf, 0, bytesRead);


Mime
View raw message