From f99887755a2d13bd173402512cca46cbbf7410b0 Mon Sep 17 00:00:00 2001
From: Michael_Xu <michael_xu521@163.com>
Date: Tue, 9 Mar 2021 10:57:11 +0800
Subject: [PATCH] [mysql] Fix NPE when the application started for the first
 time and captured a empty table

This closes #119
---
 .../alibaba/ververica/cdc/debezium/DebeziumSourceFunction.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-debezium/src/main/java/com/alibaba/ververica/cdc/debezium/DebeziumSourceFunction.java b/flink-connector-debezium/src/main/java/com/alibaba/ververica/cdc/debezium/DebeziumSourceFunction.java
index 96740e89c..44f810f49 100644
--- a/flink-connector-debezium/src/main/java/com/alibaba/ververica/cdc/debezium/DebeziumSourceFunction.java
+++ b/flink-connector-debezium/src/main/java/com/alibaba/ververica/cdc/debezium/DebeziumSourceFunction.java
@@ -265,7 +265,7 @@ public class DebeziumSourceFunction<T> extends RichSourceFunction<T>
             }
         } else {
             byte[] currentState = consumer.snapshotCurrentState();
-            if (currentState == null) {
+            if (currentState == null && restoredOffsetState != null) {
                 // the consumer has been initialized, but has not yet received any data,
                 // which means we need to return the originally restored offsets
                 serializedOffset = restoredOffsetState.getBytes(StandardCharsets.UTF_8);