aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/rpc
diff options
context:
space:
mode:
authorArina Ielchiieva <arina.yelchiyeva@gmail.com>2017-02-02 11:47:19 +0000
committerParth Chandra <pchandra@maprtech.com>2017-02-03 17:42:45 -0800
commit1ec3edf01575f302b765b62317ca16c1547dbe10 (patch)
tree506c36cd5bca9311c04614a11d394f380b9008db /exec/java-exec/src/main/java/org/apache/drill/exec/rpc
parentc8fbc386c93484b05307f77efe88333746cb8a5e (diff)
DRILL-5238: CTTAS: unable to resolve temporary table if workspace is indicated without schema
This closes #736
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/rpc')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserSession.java8
1 files changed, 2 insertions, 6 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserSession.java b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserSession.java
index 27bf3e9a9..c1e577df9 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserSession.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/rpc/user/UserSession.java
@@ -65,8 +65,8 @@ public class UserSession implements Closeable {
private boolean supportComplexTypes = false;
private UserCredentials credentials;
- private Map<String, String> properties;
private OptionManager sessionOptions;
+ private final Map<String, String> properties;
private final AtomicInteger queryCount;
private final String sessionId;
@@ -121,7 +121,6 @@ public class UserSession implements Closeable {
}
public Builder withUserProperties(UserProperties properties) {
- userSession.properties = Maps.newHashMap();
if (properties != null) {
for (int i = 0; i < properties.getPropertiesCount(); i++) {
final Property property = properties.getProperties(i);
@@ -157,6 +156,7 @@ public class UserSession implements Closeable {
sessionId = UUID.randomUUID().toString();
temporaryTables = Maps.newConcurrentMap();
temporaryLocations = Maps.newConcurrentMap();
+ properties = Maps.newHashMap();
}
public boolean isSupportComplexTypes() {
@@ -189,10 +189,6 @@ public class UserSession implements Closeable {
return properties.get(IMPERSONATION_TARGET);
}
- public String getDefaultSchemaName() {
- return getProp(SCHEMA);
- }
-
public void incrementQueryCount(final QueryCountIncrementer incrementer) {
assert incrementer != null;
queryCount.incrementAndGet();