diff options
Diffstat (limited to 'exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java')
-rw-r--r-- | exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java | 19 |
1 files changed, 15 insertions, 4 deletions
diff --git a/exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java b/exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java index bfbc17410..781fce31b 100644 --- a/exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java +++ b/exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java @@ -18,6 +18,7 @@ package org.apache.drill; import org.apache.drill.categories.UnlikelyTest; import org.apache.drill.common.exceptions.UserException; +import org.apache.drill.exec.planner.physical.PlannerSettings; import org.apache.drill.exec.work.ExecErrorConstants; import org.apache.drill.exec.work.foreman.SqlUnsupportedException; import org.apache.drill.exec.work.foreman.UnsupportedDataTypeException; @@ -307,14 +308,24 @@ public class TestDisabledFunctionality extends BaseTestQuery { @Test // DRILL-2848 public void testDisableDecimalCasts() throws Exception { - final String query = "select cast('1.2' as decimal(9, 2)) from cp.`employee.json` limit 1"; - errorMsgTestHelper(query, ExecErrorConstants.DECIMAL_DISABLE_ERR_MSG); + try { + alterSession(PlannerSettings.ENABLE_DECIMAL_DATA_TYPE_KEY, false); + final String query = "select cast('1.2' as decimal(9, 2)) from cp.`employee.json` limit 1"; + errorMsgTestHelper(query, ExecErrorConstants.DECIMAL_DISABLE_ERR_MSG); + } finally { + resetSessionOption(PlannerSettings.ENABLE_DECIMAL_DATA_TYPE_KEY); + } } @Test // DRILL-2848 public void testDisableDecimalFromParquet() throws Exception { - final String query = "select * from cp.`parquet/decimal_dictionary.parquet`"; - errorMsgTestHelper(query, ExecErrorConstants.DECIMAL_DISABLE_ERR_MSG); + try { + alterSession(PlannerSettings.ENABLE_DECIMAL_DATA_TYPE_KEY, false); + final String query = "select * from cp.`parquet/decimal_dictionary.parquet`"; + errorMsgTestHelper(query, ExecErrorConstants.DECIMAL_DISABLE_ERR_MSG); + } finally { + resetSessionOption(PlannerSettings.ENABLE_DECIMAL_DATA_TYPE_KEY); + } } @Test (expected = UnsupportedFunctionException.class) //DRILL-3802 |