DRILL-7072: Query with semi join fails for JDBC storage plugin

closes #1674

1 files changed, 15 insertions, 0 deletions

diff --git a/contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithMySQLIT.java b/contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithMySQLIT.java
index 049ee6022..cd6b4b841 100644
--- a/contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithMySQLIT.java
+++ b/contrib/storage-jdbc/src/test/java/org/apache/drill/exec/store/jdbc/TestJdbcPluginWithMySQLIT.java
@@ -308,4 +308,19 @@ public class TestJdbcPluginWithMySQLIT extends ClusterTest {
         .baselineValues(5, 5)
         .go();
   }
+
+  @Test
+  public void testSemiJoin() throws Exception {
+    String query =
+        "select person_id from mysql.`drill_mysql_test`.person t1\n" +
+            "where exists (" +
+                "select person_id from mysql.`drill_mysql_test`.person\n" +
+                "where t1.person_id = person_id)";
+    testBuilder()
+        .sqlQuery(query)
+        .unOrdered()
+        .baselineColumns("person_id")
+        .baselineValuesForSingleColumn(1, 2, 3, 5)
+        .go();
+  }
 }