[kylin] branch master updated: real-time stream support diff database hive table in lambda mode

[xxyu]

This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/master by this push:
     new 9d7ee86  real-time stream support diff database hive table in lambda 
mode
9d7ee86 is described below

commit 9d7ee863304220c5fb53a4c88cb798ed3edb0891
Author: liukun4515 <liu...@apache.org>
AuthorDate: Mon Mar 1 11:32:06 2021 +0800

    real-time stream support diff database hive table in lambda mode
---
 .../java/org/apache/kylin/rest/controller/StreamingV2Controller.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/server-base/src/main/java/org/apache/kylin/rest/controller/StreamingV2Controller.java
 
b/server-base/src/main/java/org/apache/kylin/rest/controller/StreamingV2Controller.java
index a62da8a..1b5a81e 100644
--- 
a/server-base/src/main/java/org/apache/kylin/rest/controller/StreamingV2Controller.java
+++ 
b/server-base/src/main/java/org/apache/kylin/rest/controller/StreamingV2Controller.java
@@ -500,7 +500,6 @@ public class StreamingV2Controller extends BasicController {
 
     private TableDesc deserializeTableDesc(StreamingRequestV2 
streamingRequest) {
         TableDesc desc = null;
-        String db = 
KylinConfig.getInstanceFromEnv().getHiveDatabaseLambdaCube();
         try {
             logger.debug("Saving TableDesc " + 
streamingRequest.getTableData());
             desc = JsonUtil.readValue(streamingRequest.getTableData(), 
TableDesc.class);
@@ -518,7 +517,7 @@ public class StreamingV2Controller extends BasicController {
         Preconditions.checkNotNull(desc, "Failed to deserialize from TableDesc 
definition");
         String[] dbTable = HadoopUtil.parseHiveTableName(desc.getName());
         desc.setName(dbTable[1]);
-        desc.setDatabase(db);
+        desc.setDatabase(dbTable[0]);
         desc.getIdentity();
         return desc;
     }