You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by vi...@apache.org on 2018/08/11 11:51:55 UTC

[drill] 01/03: DRILL-6649: Query with unnest of column from nested star subquery fails

This is an automated email from the ASF dual-hosted git repository.

vitalii pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git

commit 9a90164ceedc65f33e3a01d3e55282d19de8009b
Author: Volodymyr Vysotskyi <vv...@gmail.com>
AuthorDate: Thu Jul 26 16:04:10 2018 +0300

    DRILL-6649: Query with unnest of column from nested star subquery fails
    
    closes #1421
---
 .../impl/lateraljoin/TestE2EUnnestAndLateral.java        | 16 ++++++++++++++++
 pom.xml                                                  |  2 +-
 2 files changed, 17 insertions(+), 1 deletion(-)

diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/lateraljoin/TestE2EUnnestAndLateral.java b/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/lateraljoin/TestE2EUnnestAndLateral.java
index cc9c14a..0d752a2 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/lateraljoin/TestE2EUnnestAndLateral.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/lateraljoin/TestE2EUnnestAndLateral.java
@@ -607,4 +607,20 @@ public class TestE2EUnnestAndLateral extends ClusterTest {
         .build().run();
   }
 
+  @Test
+  public void testUnnestNestedStarSubquery() throws Exception {
+    String sql = "select t2.o.o_id o_id\n" +
+        "from (select * from cp.`lateraljoin/nested-customer.json` limit 1) t,\n" +
+        "unnest(t.orders) t2(o)";
+
+    testBuilder()
+        .sqlQuery(sql)
+        .unOrdered()
+        .baselineColumns("o_id")
+        .baselineValues(1L)
+        .baselineValues(2L)
+        .baselineValues(3L)
+        .go();
+  }
+
 }
diff --git a/pom.xml b/pom.xml
index a68c0b6..691d9fe 100644
--- a/pom.xml
+++ b/pom.xml
@@ -45,7 +45,7 @@
     <dep.guava.version>18.0</dep.guava.version>
     <forkCount>2</forkCount>
     <parquet.version>1.10.0</parquet.version>
-    <calcite.version>1.16.0-drill-r6</calcite.version>
+    <calcite.version>1.16.0-drill-r7</calcite.version>
     <avatica.version>1.11.0</avatica.version>
     <janino.version>2.7.6</janino.version>
     <sqlline.version>1.1.9-drill-r7</sqlline.version>