Feature: trun off mse-task notification & modify is_nullable default …

…value (#378)
miotech · Jan 15, 2021 · 904065e · 904065e
1 parent a2f096a
commit 904065e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/...-data-platform-web/src/main/java/com/miotech/kun/dataplatform/notify/ZhongdaNotifier.java b/...-data-platform-web/src/main/java/com/miotech/kun/dataplatform/notify/ZhongdaNotifier.java
@@ -6,7 +6,6 @@
 import com.miotech.kun.workflow.core.event.Event;
 import com.miotech.kun.workflow.core.event.TaskAttemptStatusChangeEvent;
 import com.miotech.kun.workflow.operator.spark.clients.HttpApiClient;
-import org.json.simple.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.util.List;
@@ -54,7 +53,7 @@ public void sendMessage(String content, List<String> users) {
     @Override
     public void notify(Event event) {
         TaskAttemptStatusChangeEvent taskAttemptStatusChangeEvent = (TaskAttemptStatusChangeEvent) event;
-        if(taskAttemptStatusChangeEvent.getToStatus().isFailure() ){
+        if(taskAttemptStatusChangeEvent.getToStatus().isFailure() && !"mse-task".equals(taskAttemptStatusChangeEvent.getTaskName())){
             String msg = buildMessage(taskAttemptStatusChangeEvent);
             List<String> users = deployedTaskService.getUserByTaskId(taskAttemptStatusChangeEvent.getTaskId());
             sendMessage(msg, users);

diff --git a/kun-metadata/kun-metadata-common/src/main/resources/sql/V7__alter_db.sql b/kun-metadata/kun-metadata-common/src/main/resources/sql/V7__alter_db.sql
@@ -1,2 +1,2 @@
 ALTER TABLE kun_mt_dataset_field ADD COLUMN "is_primary_key" BOOLEAN DEFAULT FALSE;
-ALTER TABLE kun_mt_dataset_field ADD COLUMN "is_nullable" BOOLEAN DEFAULT FALSE;
+ALTER TABLE kun_mt_dataset_field ADD COLUMN "is_nullable" BOOLEAN DEFAULT TRUE;