From bba800eb968660ce21974757cfbf0840422259a8 Mon Sep 17 00:00:00 2001
From: winger <winger2049@gmail.com>
Date: Mon, 17 Dec 2018 16:14:55 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=BC=80=E5=90=AFgtid?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8C=E5=90=8C=E6=97=B6=E5=BC=80=E5=90=AFtsdb?=
 =?UTF-8?q?=E5=90=8Egtid=20=E5=B1=9E=E6=80=A7=E4=B8=A2=E5=A4=B1=E7=9A=84?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

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 35e98f73..4d7b0a64 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
@@ -813,7 +813,9 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
         }
 
         if (logPosition.getPostion() != null) {
-            return logPosition.getPostion();
+            EntryPosition position = logPosition.getPostion();
+            position.setGtid(endPosition.getGtid());
+            return position;
         } else {
             return null;
         }