From 23bdc7a95b3a3575d4b8a77a727ba65275df8916 Mon Sep 17 00:00:00 2001 From: manmao Date: Mon, 16 Aug 2021 00:05:59 +0800 Subject: [PATCH] [postgres] Fix Validator didn't implement Serializable Co-authored-by: mao.man@rootcloud.com --- .../src/main/java/com/ververica/cdc/debezium/Validator.java | 4 +++- .../com/ververica/cdc/connectors/mysql/MySqlValidator.java | 3 +-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/Validator.java b/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/Validator.java index c5e219649..133392bd7 100644 --- a/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/Validator.java +++ b/flink-connector-debezium/src/main/java/com/ververica/cdc/debezium/Validator.java @@ -18,8 +18,10 @@ package com.ververica.cdc.debezium; +import java.io.Serializable; + /** Validator to validate the connected database satisfies the cdc connector's requirements. */ -public interface Validator { +public interface Validator extends Serializable { void validate(); diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlValidator.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlValidator.java index 6fd8d5504..13afcbcfe 100644 --- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlValidator.java +++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/MySqlValidator.java @@ -28,7 +28,6 @@ import com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils; import com.ververica.cdc.debezium.Validator; import io.debezium.connector.mysql.MySqlConnection; -import java.io.Serializable; import java.sql.SQLException; import java.util.Arrays; import java.util.Properties; @@ -37,7 +36,7 @@ import java.util.Properties; * The validator for MySql: it only cares about the version of the database is larger than or equal * to 5.7. It also requires the binlog format in the database is ROW and row image is FULL. */ -public class MySqlValidator implements Validator, Serializable { +public class MySqlValidator implements Validator { private static final long serialVersionUID = 1L;