From 6fe3ef43d86f77718ea701136c705b3cbc08e3cf Mon Sep 17 00:00:00 2001 From: winger Date: Sat, 25 Aug 2018 09:17:13 +0800 Subject: [PATCH] =?UTF-8?q?fix=20bug:=20=E5=B9=B6=E8=A1=8C=E8=A7=A3?= =?UTF-8?q?=E6=9E=90=E6=A8=A1=E5=BC=8F=E4=B8=8B=EF=BC=8C=E5=BC=80=E5=90=AF?= =?UTF-8?q?gtid=20=E4=BC=9A=E5=AF=BC=E8=87=B4=E8=A7=A3=E6=9E=90=E9=94=99?= =?UTF-8?q?=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java index 5e679639..cb579961 100644 --- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java +++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java @@ -170,7 +170,7 @@ public class LogEventConvert extends AbstractCanalLifeCycle implements BinlogPar return entryBuilder.build(); } - public Entry parseGTIDLogEvent(GtidLogEvent logEvent) { + private Entry parseGTIDLogEvent(GtidLogEvent logEvent) { LogHeader logHeader = logEvent.getHeader(); String value = logEvent.getSid().toString() + ":" + logEvent.getGno(); Pair.Builder builder = Pair.newBuilder();