From b1f052d800bae05bbf36b3594fe3c171ea4cede4 Mon Sep 17 00:00:00 2001 From: adeneche Date: Tue, 8 Mar 2016 16:54:31 +0100 Subject: [PATCH] DRILL-4487: add unit test for DRILL-4449 --- .../store/parquet/TestParquetMetadataCache.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetMetadataCache.java b/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetMetadataCache.java index 0b8b7d9227f..4330c96471e 100644 --- a/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetMetadataCache.java +++ b/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/TestParquetMetadataCache.java @@ -161,6 +161,22 @@ public void testCacheWithSubschema() throws Exception { Assert.assertEquals(25, rowCount); } + @Test + public void testFix4449() throws Exception { + runSQL("CREATE TABLE dfs_test.tmp.`4449` PARTITION BY(l_discount) AS SELECT l_orderkey, l_discount FROM cp.`tpch/lineitem.parquet`"); + runSQL("REFRESH TABLE METADATA dfs_test.tmp.`4449`"); + + testBuilder() + .sqlQuery("SELECT COUNT(*) cnt FROM (" + + "SELECT l_orderkey FROM dfs_test.tmp.`4449` WHERE l_discount < 0.05" + + " UNION ALL" + + " SELECT l_orderkey FROM dfs_test.tmp.`4449` WHERE l_discount > 0.02)") + .unOrdered() + .baselineColumns("cnt") + .baselineValues(71159L) + .go(); + } + private void checkForMetadataFile(String table) throws Exception { String tmpDir = getDfsTestTmpSchemaLocation(); String metaFile = Joiner.on("/").join(tmpDir, table, Metadata.METADATA_FILENAME);