fixed issue alibaba#650 , IndexOutOfBoundsException

xiaoshizijiayou · Dec 8, 2018 · 322b4de · 322b4de
1 parent 9b01298
commit 322b4de
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/node/etl/src/main/java/com/alibaba/otter/node/etl/select/selector/MessageParser.java b/node/etl/src/main/java/com/alibaba/otter/node/etl/select/selector/MessageParser.java
@@ -107,7 +107,10 @@ public List<EventData> parse(Long pipelineId, List<Entry> datas) throws SelectEx
                         if (isMarkTable) {
                             RowChange rowChange = RowChange.parseFrom(entry.getStoreValue());
                             if (!rowChange.getIsDdl()) {
-                                int loopback = checkLoopback(pipeline, rowChange.getRowDatas(0));
+                                int loopback = 0;
+                                if (rowChange.getRowDatasCount() > 0) {
+                                    loopback = checkLoopback(pipeline, rowChange.getRowDatas(0));
+                                }
                                 if (loopback == 2) {
                                     needLoopback |= true; // 只处理正常同步产生的回环数据
                                 }
@@ -122,7 +125,10 @@ public List<EventData> parse(Long pipelineId, List<Entry> datas) throws SelectEx
                         if (isCompatibleLoopback) {
                             RowChange rowChange = RowChange.parseFrom(entry.getStoreValue());
                             if (!rowChange.getIsDdl()) {
-                                int loopback = checkCompatibleLoopback(pipeline, rowChange.getRowDatas(0));
+                                int loopback = 0;
+                                if (rowChange.getRowDatasCount() > 0) {
+                                    loopback = checkCompatibleLoopback(pipeline, rowChange.getRowDatas(0));
+                                }
                                 if (loopback == 2) {
                                     needLoopback |= true; // 只处理正常同步产生的回环数据
                                 }