This is an automated email from the ASF dual-hosted git repository.

jackylk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/carbondata.git


The following commit(s) were added to refs/heads/master by this push:
     new e14c817  [CARBONDATA-3485] Data loading is failed from S3 to hdfs 
table having ~2K carbonfiles
e14c817 is described below

commit e14c8173a0a59a16af0c28a82dd0d96d97d990a3
Author: BJangir <[email protected]>
AuthorDate: Thu Aug 1 20:20:07 2019 +0530

    [CARBONDATA-3485] Data loading is failed from S3 to hdfs table having ~2K 
carbonfiles
    
    This closes #3346
---
 .../result/iterator/AbstractDetailQueryResultIterator.java     | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/core/src/main/java/org/apache/carbondata/core/scan/result/iterator/AbstractDetailQueryResultIterator.java
 
b/core/src/main/java/org/apache/carbondata/core/scan/result/iterator/AbstractDetailQueryResultIterator.java
index d7f2c0b..9144bd8 100644
--- 
a/core/src/main/java/org/apache/carbondata/core/scan/result/iterator/AbstractDetailQueryResultIterator.java
+++ 
b/core/src/main/java/org/apache/carbondata/core/scan/result/iterator/AbstractDetailQueryResultIterator.java
@@ -217,12 +217,12 @@ public abstract class 
AbstractDetailQueryResultIterator<E> extends CarbonIterato
   }
 
   private DataBlockIterator getDataBlockIterator() {
+    try {
+      fileReader.finish();
+    } catch (IOException e) {
+      throw new RuntimeException(e);
+    }
     if (blockExecutionInfos.size() > 0) {
-      try {
-        fileReader.finish();
-      } catch (IOException e) {
-        throw new RuntimeException(e);
-      }
       BlockExecutionInfo executionInfo = blockExecutionInfos.get(0);
       blockExecutionInfos.remove(executionInfo);
       return new DataBlockIterator(executionInfo, fileReader, batchSize, 
queryStatisticsModel,

Reply via email to