aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/test/java/org/apache/drill/TestDisabledFunctionality.java
diff options
context:
space:
mode:
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.java19
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