You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@drill.apache.org by ja...@apache.org on 2014/04/20 06:08:22 UTC
[14/17] git commit: DRILL-405: Fix for not able to query directory
containing json files
DRILL-405: Fix for not able to query directory containing json files
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/fefda25e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/fefda25e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/fefda25e
Branch: refs/heads/master
Commit: fefda25e71da4f764a8559cf511441392b2258a8
Parents: 9d7bb06
Author: Steven Phillips <sp...@maprtech.com>
Authored: Thu Mar 27 14:07:00 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
Committed: Sat Apr 19 21:07:28 2014 -0700
----------------------------------------------------------------------
.../org/apache/drill/exec/store/easy/json/JSONRecordReader.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/fefda25e/exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/JSONRecordReader.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/JSONRecordReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/JSONRecordReader.java
index fb23a09..2e8cd2e 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/JSONRecordReader.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/easy/json/JSONRecordReader.java
@@ -104,6 +104,7 @@ public class JSONRecordReader implements RecordReader {
@Override
public void setup(OutputMutator output) throws ExecutionSetupException {
outputMutator = output;
+ output.removeAllFields();
currentSchema = new ObjectSchema();
diffSchema = new DiffSchema();
removedFields = Lists.newArrayList();