You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
skipUpdateBeforeEvent -> sink: order customer adress) (1/1)#8 (76caadbd101f8365d84ef4a6e8487a) switched frOm INITIALIZING tO FAIL 'failure cause: org.apache.flink,table.api.validationxception: Currently flink Mysgl coc conector only supports Mysgl whose version is
larger or equal to 5.7,but actual is 5.6.at com.ververica.cdc.connectors.mysgl.MySqlValidator.checkVersion(MysglValidator .java:111)at com.ververica.cdc.connectors.mysgl.MysalValidator,validate(MysalValidator,iava:73)at com.ververica.cdc.debezium.DebeziumSourceFunction,open(DebeziumSourceFunction.iava:215)at org.apache.flink.api.common.functions.util.functionUtils.openFunction(FunctionUtils.java:34)at org.apache.flink.streaming.api.operators.AbstractUdfstreamoperator,open(AbstractUdfstreamoperator.java:102)at org.apache.flink.streaming.runtime.tasks.0peratorchain.initializestateAndopenoperators(0peratorchain.java:437)at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:582)at org.apache.flink.streaming.runtime.tasks.streamTaskActionExecutor$synchronizedstreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100)
由于mysql本身的原因在flink运行时校验出错
入口:com.ververica.cdc.connectors.mysgl.MySqlValidator.checkVersion
可以将以上MySqlValidator.checkVersion 这段对MySQL 数据库的校验放置到
com.qlangtech.tis.plugins.incr.flink.cdc.mysql.FlinkCDCMySQLSourceFactory
表单验证逻辑中进行校验The text was updated successfully, but these errors were encountered: