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);