From 4e9e3f5abe243ea6a85fbb438fdf7c90adb6abf2 Mon Sep 17 00:00:00 2001
From: agapple <jianghang115@gmail.com>
Date: Sun, 25 Nov 2018 21:17:34 +0800
Subject: [PATCH] fixed issue #1192 , NPE test

---
 .../otter/canal/parse/inbound/mysql/MysqlEventParser.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
index 0528d19c..35e98f73 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
@@ -135,6 +135,10 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
     protected void afterDump(ErosaConnection connection) {
         super.afterDump(connection);
 
+        if (connection == null) {
+            throw new CanalParseException("illegal connection is null");
+        }
+
         if (!(connection instanceof MysqlConnection)) {
             throw new CanalParseException("Unsupported connection type : " + connection.getClass().getSimpleName());
         }