diff options
author | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2017-02-02 11:47:19 +0000 |
---|---|---|
committer | Parth Chandra <pchandra@maprtech.com> | 2017-02-03 17:42:45 -0800 |
commit | 1ec3edf01575f302b765b62317ca16c1547dbe10 (patch) | |
tree | 506c36cd5bca9311c04614a11d394f380b9008db /exec/java-exec/src/main/java/org/apache/drill/exec/rpc | |
parent | c8fbc386c93484b05307f77efe88333746cb8a5e (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.java | 8 |
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(); |