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

gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 6586c9f  [INLONG-687] set schemaName to m0_day when save business in 
inlong-manager (#524)
6586c9f is described below

commit 6586c9fe6bdeb560ba024d5d533c2e0db52161ac
Author: healchow <[email protected]>
AuthorDate: Fri Jul 9 09:46:14 2021 +0800

    [INLONG-687] set schemaName to m0_day when save business in inlong-manager 
(#524)
    
    Co-authored-by: healzhou <[email protected]>
---
 .../apache/inlong/manager/common/enums/BizConstant.java   | 15 +--------------
 .../manager/service/core/impl/BusinessServiceImpl.java    |  5 ++++-
 2 files changed, 5 insertions(+), 15 deletions(-)

diff --git 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/BizConstant.java
 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/BizConstant.java
index 50ee895..507a253 100644
--- 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/BizConstant.java
+++ 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/BizConstant.java
@@ -19,7 +19,6 @@ package org.apache.inlong.manager.common.enums;
 
 /**
  * Constant for business
- *
  */
 public class BizConstant {
 
@@ -35,21 +34,9 @@ public class BizConstant {
 
     public static final String DATA_TYPE_KEY_VALUE = "KEY-VALUE";
 
-    public static final String DATA_TYPE_PB = "PB";
-
     public static final String MIDDLEWARE_TYPE_TUBE = "TUBE";
 
-    public static final String CLUSTER_TYPE_ZK = "ZOOKEEPER";
-
-    public static final String CLUSTER_TYPE_SORT_ZK = "SORT_ZK";
-
-    public static final String CLUSTER_TYPE_SORT_TOPO = "SORT_TOPO";
-
-    public static final String CLUSTER_GROUP = "CLUSTER_GROUP";
-
-    public static final String MIDDLEWARE_TOPIC = "topic";
-
-    public static final String MIDDLEWARE_NAMESPACE = "namespace";
+    public static final String SCHEMA_M0_DAY = "m0_day";
 
     public static final String BID_IS_EMPTY = "businessIdentifier is empty";
 
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
index caf4070..e59621a 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/BusinessServiceImpl.java
@@ -91,7 +91,10 @@ public class BusinessServiceImpl implements BusinessService {
         entity.setBusinessIdentifier(bid);
         entity.setMqResourceObj(topic);
 
-        // After saving, the status is set to [Waiting to submit]
+        // Only M0 is currently supported
+        entity.setSchemaName(BizConstant.SCHEMA_M0_DAY);
+
+        // After saving, the status is set to [BIZ_WAIT_APPLYING]
         entity.setStatus(EntityStatus.BIZ_WAIT_APPLYING.getCode());
 
         entity.setCreator(operator);

Reply via email to