1. Fix compressed OSS binlog data

2. Fix first second data loss caused by dumping from OSS binlog

Author: dingxiaobo

parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinLogConnection.java

@@ -118,7 +118,7 @@ public void dump(String binlogfilename, Long binlogPosition, SinkFunction func)
                     if (!iterateEvents.isEmpty()) {
                         // 处理compress event
                         for(LogEvent itEvent : iterateEvents) {
-                            if (!func.sink(event)) {
+                            if (!func.sink(itEvent)) {
                                 needContinue = false;
                                 break;
                             }
@@ -210,7 +210,8 @@ public void dump(long timestampMills, SinkFunction func) throws IOException {
                     if (event != null) {
                         checkServerId(event);
 
-                        if (event.getWhen() > timestampSeconds) {
+                        // 闭区间，防止丢开始那一秒的数据
+                        if (event.getWhen() >= timestampSeconds) {
                             break;
                         }