From 30a3ed117e785595943b4be16f51c81780d2ea27 Mon Sep 17 00:00:00 2001 From: kangkaisen Date: Fri, 26 May 2017 12:30:17 +0800 Subject: [PATCH] KYLIN-2652 Make kylinConfig threadsafe in CubeVisitService --- .../hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java index cde127e92..c66af66d9 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/CubeVisitService.java @@ -238,9 +238,8 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement region.startRegionOperation(); // if user change kylin.properties on kylin server, need to manually redeploy coprocessor jar to update KylinConfig of Env. - String serverPropString = request.getKylinProperties(); - KylinConfig.setKylinConfigInEnvIfMissing(serverPropString); - KylinConfig kylinConfig = KylinConfig.getInstanceFromEnv(); + KylinConfig kylinConfig = KylinConfig.createKylinConfig(request.getKylinProperties()); + KylinConfig.setKylinConfigThreadLocal(kylinConfig); debugGitTag = region.getTableDesc().getValue(IRealizationConstants.HTableGitTag); @@ -425,8 +424,6 @@ public class CubeVisitService extends CubeVisitProtos.CubeVisitService implement @Override public void stop(CoprocessorEnvironment env) throws IOException { - // destroy KylinConfig when coprocessor stop - KylinConfig.destroyInstance(); } @Override -- 2.11.0 (Apple Git-81)