aboutsummaryrefslogtreecommitdiff
path: root/contrib/storage-hive
diff options
context:
space:
mode:
authorPaul Rogers <progers@maprtech.com>2017-10-02 15:45:21 -0700
committerArina Ielchiieva <arina.yelchiyeva@gmail.com>2017-11-13 14:59:19 +0200
commit42fc11e53557477ac01c7dd31c3aa93e22fb4384 (patch)
tree6b7fcfedbefeceba55d03abdc5c45f1826b576ec /contrib/storage-hive
parent3036d3700aa620bbbffc260e52f633cdaae1172c (diff)
DRILL-5832: Change OperatorFixture to use system option manager
- Rename FixtureBuilder to ClusterFixtureBuilder - Provide alternative way to reset system/session options - Fix for DRILL-5833: random failure in TestParquetWriter - Provide strict, but clear, errors for missing options closes #970
Diffstat (limited to 'contrib/storage-hive')
-rw-r--r--contrib/storage-hive/core/src/test/java/org/apache/drill/exec/hive/TestHiveStorage.java7
1 files changed, 2 insertions, 5 deletions
diff --git a/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/hive/TestHiveStorage.java b/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/hive/TestHiveStorage.java
index efd26ff06..cf987974e 100644
--- a/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/hive/TestHiveStorage.java
+++ b/contrib/storage-hive/core/src/test/java/org/apache/drill/exec/hive/TestHiveStorage.java
@@ -26,7 +26,6 @@ import org.apache.drill.common.exceptions.UserRemoteException;
import org.apache.drill.exec.ExecConstants;
import org.apache.drill.exec.planner.physical.PlannerSettings;
import org.apache.drill.exec.proto.UserProtos;
-import org.apache.drill.test.OperatorFixture;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.hive.common.type.HiveVarchar;
import org.joda.time.DateTime;
@@ -73,10 +72,8 @@ public class TestHiveStorage extends HiveTestBase {
.baselineValues(200L)
.go();
} finally {
- final OperatorFixture.TestOptionSet testOptionSet = new OperatorFixture.TestOptionSet();
- test(String.format("alter session set `%s` = %s",
- ExecConstants.HIVE_OPTIMIZE_SCAN_WITH_NATIVE_READERS,
- Boolean.toString(testOptionSet.getDefault(ExecConstants.HIVE_OPTIMIZE_SCAN_WITH_NATIVE_READERS).bool_val)));
+ test("alter session reset `%s`",
+ ExecConstants.HIVE_OPTIMIZE_SCAN_WITH_NATIVE_READERS);
}
}