Repository: lens Updated Branches: refs/heads/master 6c40b24ff -> 0ea84729a
LENS-1458 : RESULT_SET_PARENT_DIR set at driver level getting overwritten for queued queries after server restart Project: http://git-wip-us.apache.org/repos/asf/lens/repo Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/0ea84729 Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/0ea84729 Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/0ea84729 Branch: refs/heads/master Commit: 0ea84729ad0a1fccccf0ee7869f43600bcd38bdf Parents: 6c40b24 Author: Sushil Mohanty <[email protected]> Authored: Mon Aug 7 18:38:15 2017 +0530 Committer: sushilmohanty <[email protected]> Committed: Mon Aug 7 18:38:15 2017 +0530 ---------------------------------------------------------------------- .../apache/lens/server/api/query/DriverSelectorQueryContext.java | 2 +- .../src/test/java/org/apache/lens/server/TestServerRestart.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/lens/blob/0ea84729/lens-server-api/src/main/java/org/apache/lens/server/api/query/DriverSelectorQueryContext.java ---------------------------------------------------------------------- diff --git a/lens-server-api/src/main/java/org/apache/lens/server/api/query/DriverSelectorQueryContext.java b/lens-server-api/src/main/java/org/apache/lens/server/api/query/DriverSelectorQueryContext.java index 41e533e..9cec42a 100644 --- a/lens-server-api/src/main/java/org/apache/lens/server/api/query/DriverSelectorQueryContext.java +++ b/lens-server-api/src/main/java/org/apache/lens/server/api/query/DriverSelectorQueryContext.java @@ -254,7 +254,7 @@ public class DriverSelectorQueryContext { } public void setDriverConf(LensDriver driver, Configuration conf) { - driverQueryContextMap.get(driver).setDriverSpecificConf(conf); + driverQueryContextMap.get(driver).setDriverSpecificConf(mergeConf(driver, conf)); } public void setDriverCost(LensDriver driver, QueryCost cost) { http://git-wip-us.apache.org/repos/asf/lens/blob/0ea84729/lens-server/src/test/java/org/apache/lens/server/TestServerRestart.java ---------------------------------------------------------------------- diff --git a/lens-server/src/test/java/org/apache/lens/server/TestServerRestart.java b/lens-server/src/test/java/org/apache/lens/server/TestServerRestart.java index 20aa8cb..8b7728e 100644 --- a/lens-server/src/test/java/org/apache/lens/server/TestServerRestart.java +++ b/lens-server/src/test/java/org/apache/lens/server/TestServerRestart.java @@ -39,6 +39,7 @@ import org.apache.lens.api.APIResult.Status; import org.apache.lens.api.query.*; import org.apache.lens.api.result.LensAPIResult; import org.apache.lens.driver.hive.TestRemoteHiveDriver; +import org.apache.lens.server.api.LensConfConstants; import org.apache.lens.server.api.error.LensException; import org.apache.lens.server.api.query.QueryContext; import org.apache.lens.server.api.query.QueryExecutionService; @@ -245,6 +246,7 @@ public class TestServerRestart extends LensAllApplicationJerseyTest { assertEquals(lensQueryConf.getProperty(KEY_POST_SELECT), VALUE_POST_SELECT); if (afterRestart) { + assertEquals(driverConf.get(LensConfConstants.RESULT_SET_PARENT_DIR), "target/hive-lens-results"); //This will be unavailable since if was not updated in LensConf by MockDriverQueryHook assertNull(driverConf.get(UNSAVED_KEY_POST_SELECT)); } else {
