[kylin] branch master updated: streaming cube just supports the MR engine

[xx...@apache.org]

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 39d7909  streaming cube just supports the MR engine
39d7909 is described below

commit 39d790965675a18833dc00b5ec1502775c166396
Author: liukun4515 <li...@apache.org>
AuthorDate: Tue Jul 13 11:43:33 2021 +0800

    streaming cube just supports the MR engine
---
 .../java/org/apache/kylin/rest/controller/CubeController.java     | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java b/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java
index 4510fe4..98788d8 100644
--- a/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java
+++ b/server-base/src/main/java/org/apache/kylin/rest/controller/CubeController.java
@@ -869,6 +869,14 @@ public class CubeController extends BasicController {
 
             validateColumnFamily(desc);
 
+            // check build engine for stream cube
+            if (desc.isStreamingCube()) {
+                if (desc.getEngineType() != IEngineAware.ID_MR_V2) {
+                    logger.info("streaming cube just supports MR engine");
+                    throw new BadRequestException("Invalid Engine type, Streaming cube just supports MapReduce engine");
+                }
+            }
+
             //cube renaming is not allowed
             if (!cube.getDescriptor().getName().equalsIgnoreCase(desc.getName())) {
                 String error = "Cube Desc renaming is not allowed: desc.getName(): " + desc.getName()