From adccc0e9120bc561f5ccc6084b0ea1fa73e2693f Mon Sep 17 00:00:00 2001 From: agapple Date: Wed, 19 Jun 2019 15:04:22 +0800 Subject: [PATCH] add logger info for query_log_event --- .../com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java | 6 ++---- deployer/src/main/resources/canal.properties | 3 +-- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java index c732da99..8cc49795 100644 --- a/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java +++ b/dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java @@ -706,10 +706,8 @@ public class QueryLogEvent extends LogEvent { * That's why you must write status vars in growing * order of code */ - if (logger.isDebugEnabled()) { - logger.debug("Query_log_event has unknown status vars (first has code: " + code - + "), skipping the rest of them"); - } + logger.error("Query_log_event has unknown status vars (first has code: " + code + + "), skipping the rest of them"); break; // Break loop } } diff --git a/deployer/src/main/resources/canal.properties b/deployer/src/main/resources/canal.properties index d7f6b102..106005f1 100644 --- a/deployer/src/main/resources/canal.properties +++ b/deployer/src/main/resources/canal.properties @@ -129,5 +129,4 @@ canal.mq.accessChannel = local ################################################## canal.mq.kafka.kerberos.enable = false canal.mq.kafka.kerberos.krb5FilePath = "../conf/kerberos/krb5.conf" -canal.mq.kafka.kerberos.jaasFilePath = "../conf/kerberos/jaas.conf" - +canal.mq.kafka.kerberos.jaasFilePath = "../conf/kerberos/jaas.conf" \ No newline at end of file