carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chenliang...@apache.org
Subject [1/2] incubator-carbondata git commit: Main process is not exiting even after program completes
Date Thu, 07 Jul 2016 17:12:43 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master ea890a4f2 -> 781eff538


Main process is not exiting even after program completes


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

Branch: refs/heads/master
Commit: 0d81b168e7189a8c142590332cadc9a668f4a14e
Parents: ea890a4
Author: ravipesala <ravi.pesala@gmail.com>
Authored: Wed Jul 6 18:58:52 2016 +0530
Committer: chenliang613 <chenliang613@apache.org>
Committed: Thu Jul 7 22:40:12 2016 +0530

----------------------------------------------------------------------
 .../scan/result/iterator/DetailQueryResultIterator.java          | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/0d81b168/core/src/main/java/org/carbondata/scan/result/iterator/DetailQueryResultIterator.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/carbondata/scan/result/iterator/DetailQueryResultIterator.java
b/core/src/main/java/org/carbondata/scan/result/iterator/DetailQueryResultIterator.java
index 4eb50ac..890f9da 100644
--- a/core/src/main/java/org/carbondata/scan/result/iterator/DetailQueryResultIterator.java
+++ b/core/src/main/java/org/carbondata/scan/result/iterator/DetailQueryResultIterator.java
@@ -23,6 +23,7 @@ import java.util.concurrent.Callable;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
+import java.util.concurrent.TimeUnit;
 
 import org.carbondata.scan.executor.exception.QueryExecutionException;
 import org.carbondata.scan.executor.infos.BlockExecutionInfo;
@@ -66,9 +67,12 @@ public class DetailQueryResultIterator extends AbstractDetailQueryResultIterator
         future = execute();
       } else {
         fileReader.finish();
+        execService.shutdown();
+        execService.awaitTermination(2, TimeUnit.HOURS);
       }
     } catch (Exception ex) {
       fileReader.finish();
+      execService.shutdown();
       throw new RuntimeException(ex.getCause().getMessage());
     }
     return result;


Mime
View raw message