add mail logger

15981891920 · Apr 8, 2020 · 215a10b · 215a10b
1 parent f2e8d15
commit 215a10b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/kafka-eagle-api/src/main/java/org/smartloli/kafka/eagle/api/im/queue/MailJob.java b/kafka-eagle-api/src/main/java/org/smartloli/kafka/eagle/api/im/queue/MailJob.java
@@ -23,6 +23,8 @@
 import org.quartz.Job;
 import org.quartz.JobExecutionContext;
 import org.quartz.JobExecutionException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.smartloli.kafka.eagle.common.protocol.alarm.queue.BaseJobContext;
 import org.smartloli.kafka.eagle.common.util.HttpClientUtils;
 import org.smartloli.kafka.eagle.common.util.KConstants.AlarmQueue;
@@ -40,6 +42,8 @@
  */
 public class MailJob implements Job {
 
+	private Logger LOG = LoggerFactory.getLogger(MailJob.class);
+
 	/** Send alarm information by mail. */
 	public void execute(JobExecutionContext jobContext) throws JobExecutionException {
 		BaseJobContext bjc = (BaseJobContext) jobContext.getJobDetail().getJobDataMap().get(AlarmQueue.JOB_PARAMS);
@@ -51,9 +55,10 @@ private int sendMsg(String data, String url) {
 			JSONObject object = JSON.parseObject(data);
 			BasicNameValuePair address = new BasicNameValuePair("address", object.getString("address"));
 			BasicNameValuePair msg = new BasicNameValuePair("msg", object.getString("msg"));
-			HttpClientUtils.doPostForm(url, Arrays.asList(address,msg));
+			HttpClientUtils.doPostForm(url, Arrays.asList(address, msg));
 		} catch (Exception e) {
-			ThrowExceptionUtils.print(this.getClass()).error("Send alarm message has error by mail, msg is ",e);
+			ThrowExceptionUtils.print(this.getClass()).error("Send alarm message has error by mail, msg is ", e);
+			LOG.error("Send alarm message has error by mail, msg is ", e);
 			return 0;
 		}
 		return 1;

diff --git a/kafka-eagle-common/src/main/resources/system-config.properties b/kafka-eagle-common/src/main/resources/system-config.properties
@@ -45,7 +45,7 @@ kafka.eagle.metrics.retain=15
 # kafka sql topic records max
 ######################################
 kafka.eagle.sql.topic.records.max=5000
-kafka.eagle.sql.fix.error=false
+kafka.eagle.sql.fix.error=true
 
 ######################################
 # delete kafka topic token