From 5ade05711350fe190ec2898106e591dd0564f4df Mon Sep 17 00:00:00 2001 From: agapple Date: Fri, 26 Dec 2014 20:23:59 +0800 Subject: [PATCH] fixed issue #106 , logger exception --- .../com/alibaba/otter/canal/deployer/CanalController.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java index 3a112718..9a8b93a4 100644 --- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java +++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java @@ -15,6 +15,7 @@ import org.springframework.beans.factory.BeanFactory; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; +import com.alibaba.otter.canal.common.CanalException; import com.alibaba.otter.canal.common.utils.AddressUtils; import com.alibaba.otter.canal.common.zookeeper.ZkClientx; import com.alibaba.otter.canal.common.zookeeper.ZookeeperPathUtils; @@ -284,6 +285,9 @@ public class CanalController { System.setProperty(CanalConstants.CANAL_DESTINATION_PROPERTY, destination); instanceGenerator.setBeanFactory(getBeanFactory(config.getSpringXml())); return instanceGenerator.generate(destination); + } catch (Throwable e) { + logger.error("generator instance failed.", e); + throw new CanalException(e); } finally { System.setProperty(CanalConstants.CANAL_DESTINATION_PROPERTY, ""); }