From f1710f1c7fa93104d71455c928a9217cf72b4a3d Mon Sep 17 00:00:00 2001
From: machey <rewerma@163.com>
Date: Tue, 27 Nov 2018 22:39:49 +0800
Subject: [PATCH] fixed #1201

---
 .../java/com/alibaba/otter/canal/protocol/FlatMessage.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/protocol/src/main/java/com/alibaba/otter/canal/protocol/FlatMessage.java b/protocol/src/main/java/com/alibaba/otter/canal/protocol/FlatMessage.java
index 592db497..94c539cb 100644
--- a/protocol/src/main/java/com/alibaba/otter/canal/protocol/FlatMessage.java
+++ b/protocol/src/main/java/com/alibaba/otter/canal/protocol/FlatMessage.java
@@ -285,7 +285,10 @@ public class FlatMessage implements Serializable {
             if (flatMessage.getData() != null) {
                 int idx = 0;
                 for (Map<String, String> row : flatMessage.getData()) {
-                    Map<String, String> o = flatMessage.getOld().get(idx);
+                    Map<String, String> o = null;
+                    if (flatMessage.getOld() != null) {
+                        o = flatMessage.getOld().get(idx);
+                    }
                     String value;
                     // 如果old中有pk值说明主键有修改, 以旧的主键值hash为准
                     if (o != null && o.containsKey(pk)) {