You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ra...@apache.org on 2016/08/06 10:00:29 UTC
[12/20] incubator-carbondata git commit: [CARBONDATA-126] Stream not
getting close for last block in data loading (#891)
[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 <ku...@gmail.com>
Authored: Thu Aug 4 13:14:50 2016 +0530
Committer: Venkata Ramana G <g....@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) {