Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1588#discussion_r154007357
--- Diff:
integration/spark2/src/main/java/org/apache/carbondata/spark/vectorreader/VectorizedCarbonRecordReader.java
---
@@ -116,6 +117,14 @@ public VectorizedCarbonRecordReader(QueryModel
queryModel, InputMetricsStats inp
queryExecutor = QueryExecutorFactory.getQueryExecutor(queryModel);
iterator = (AbstractDetailQueryResultIterator)
queryExecutor.execute(queryModel);
} catch (QueryExecutionException e) {
+ Throwable ext = e;
+ while (ext != null) {
+ if (ext instanceof FileNotFoundException) {
+ throw new InterruptedException(
--- End diff --
better pass the exception along with message to the constructor
---
