carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipes...@apache.org
Subject [12/20] incubator-carbondata git commit: [CARBONDATA-126] Stream not getting close for last block in data loading (#891)
Date Sat, 06 Aug 2016 10:00:29 GMT
[CARBONDATA-126] Stream not getting close for last block in data loading (#891)



Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/a724831e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/a724831e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/a724831e

Branch: refs/heads/master
Commit: a724831ed6ef124b029665a6f92b7e8a848c63a8
Parents: 75ddcce
Author: Kumar Vishal <kumarvishal.1802@gmail.com>
Authored: Thu Aug 4 13:14:50 2016 +0530
Committer: Venkata Ramana G <g.ramana.v1@gmail.com>
Committed: Thu Aug 4 13:14:50 2016 +0530

----------------------------------------------------------------------
 .../org/carbondata/processing/csvreaderstep/UnivocityCsvParser.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/a724831e/processing/src/main/java/org/carbondata/processing/csvreaderstep/UnivocityCsvParser.java
----------------------------------------------------------------------
diff --git a/processing/src/main/java/org/carbondata/processing/csvreaderstep/UnivocityCsvParser.java
b/processing/src/main/java/org/carbondata/processing/csvreaderstep/UnivocityCsvParser.java
index 9594a24..01b5bf0 100644
--- a/processing/src/main/java/org/carbondata/processing/csvreaderstep/UnivocityCsvParser.java
+++ b/processing/src/main/java/org/carbondata/processing/csvreaderstep/UnivocityCsvParser.java
@@ -153,6 +153,7 @@ public class UnivocityCsvParser {
   public boolean hasMoreRecords() throws IOException {
     row = parser.parseNext();
     if (row == null && blockCounter + 1 >= this.csvParserVo.getBlockDetailsList().size())
{
+      close();
       return false;
     }
     if (row == null) {


Mime
View raw message