create table flink_ui_fat.t_flink_configuration(create table flink_ui_fat.t_flink_configuration(    id              bigint unsigned     primary key                     not null auto_increment comment '主键ID',    config_key      varchar(128)                                        not null comment '配置Key，可能是Flink配置，可能是Zeppelin配置',    default_value   varchar(512)                                        null comment '配置默认值，可以为空',    config_type     varchar(16)                                         not null comment '配置适用类型：Zeppelin的interpreter配置（interpreter）、FlinkSQL的Configuration配置（sql）、FlinkTable的Connector配置（connector）',    optional        boolean                                             not null comment '是否可选配置，如果是非可选配置，会强制配置项不为空',    multiple        boolean                                             not null comment '是否是多值配置，比如有些配置的值可能是多个选项列表，且可以同时选择多个',    accept          varchar(16)                                         not null comment '配置值输入类型：输入框（input）、下拉选择框（select）',    remark          varchar(512)                                        null comment '配置含义详细说明',    options         text                                        null comment '如果配置值输入类型为Select，那么该项可能有值，用于定义下拉枚举项，以及说明。格式为JSON：{value:"",remark:""}',    create_at       timestamp           default CURRENT_TIMESTAMP       not null comment '创建时间', modified_at     timestamp           default CURRENT_TIMESTAMP       not null comment '更新时间')

 
2021-09-30 08:01:19,886 INFO MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|streaming Waiting for keepalive thread to start [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2021-09-30 08:01:19,886 INFO MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|binlog Creating thread debezium-mysqlconnector-debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306-binlog-client [io.debezium.util.Threads] 2021-09-30 08:01:19,986 INFO MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|streaming Keepalive thread is running [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2021-09-30 08:01:20,135 ERROR MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|binlog Error during binlog processing. Last offset stored = null, binlog reader near position = mysql-bin.018172/32328687 [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2021-09-30 08:01:20,135 ERROR MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|binlog Producer failure [io.debezium.pipeline.ErrorHandler] io.debezium.DebeziumException: Error processing binlog event at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1118) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:966) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:606) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:850) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement '/* ApplicationName=DataGrip 2021.1.3 */ create table flink_ui_fat.t_flink_configuration( id bigint unsigned primary key not null auto_increment comment '??????ID', config_key varchar(128) not null comment '??????Key????????????Flink??????????????????Zeppelin??????', default_value varchar(512) null comment '??????????????????????????????', config_type varchar(16) not null comment '?????????????????????Zeppelin???interpreter?????????interpreter??????FlinkSQL???Configuration?????????sql??????FlinkTable???Connector?????????connector???', optional boolean not null comment '???????????????????????????????????????????????????????????????????????????', multiple boolean not null comment '?????????????????????????????????????????????????????????????????????????????????????????????????????????', accept varchar(16) not null comment '????????????????????????????????????input????????????????????????select???', remark varchar(512) null comment '????????????????????????', options text null comment '??????????????????????????????Select????????????????????????????????????????????????????????????????????????????????????JSON???{value:"",remark:""}', create_at timestamp default CURRENT_TIMESTAMP not null comment '????????????', modified_at timestamp default CURRENT_TIMESTAMP not null comment '????????????' )' no viable alternative at input 'create table flink_ui_fat.t_flink_configuration(\n id bigint unsigned primary key not null auto_increment comment '??????ID',\n config_key varchar(128) not null comment '??????Key????????????Flink??????????????????Zeppelin??????',\n default_value varchar(512) null comment '??????????????????????????????',\n config_type varchar(16) not null comment '?????????????????????Zeppelin???interpreter?????????interpreter??????FlinkSQL???Configuration?????????sql??????FlinkTable???Connector?????????connector???',\n optional' at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1169) at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:897) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:200) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:574) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:352) ... 5 more Caused by: org.antlr.v4.runtime.NoViableAltException at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026) at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467) at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:971) ... 13 more 2021-09-30 08:01:20,136 INFO MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|binlog Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2021-09-30 08:01:20,363 INFO || WorkerSourceTask{id=debezium_sync_mysql_source_connector_sr_dev_mysql_master_1_sr_cvte_cn_3306-0} Committing offsets [org.apache.kafka.connect.runtime.WorkerSourceTask] 2021-09-30 08:01:20,363 INFO || WorkerSourceTask{id=debezium_sync_mysql_source_connector_sr_dev_mysql_master_1_sr_cvte_cn_3306-0} flushing 0 outstanding messages for offset commit [org.apache.kafka.connect.runtime.WorkerSourceTask] 2021-09-30 08:01:20,363 ERROR || WorkerSourceTask{id=debezium_sync_mysql_source_connector_sr_dev_mysql_master_1_sr_cvte_cn_3306-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1118) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:966) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:606) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:850) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: io.debezium.DebeziumException: Error processing binlog event ... 6 more Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement '/* ApplicationName=DataGrip 2021.1.3 */ create table flink_ui_fat.t_flink_configuration( id bigint unsigned primary key not null auto_increment comment '??????ID', config_key varchar(128) not null comment '??????Key????????????Flink??????????????????Zeppelin??????', default_value varchar(512) null comment '??????????????????????????????', config_type varchar(16) not null comment '?????????????????????Zeppelin???interpreter?????????interpreter??????FlinkSQL???Configuration?????????sql??????FlinkTable???Connector?????????connector???', optional boolean not null comment '???????????????????????????????????????????????????????????????????????????', multiple boolean not null comment '?????????????????????????????????????????????????????????????????????????????????????????????????????????', accept varchar(16) not null comment '????????????????????????????????????input????????????????????????select???', remark varchar(512) null comment '????????????????????????', options text null comment '??????????????????????????????Select????????????????????????????????????????????????????????????????????????????????????JSON???{value:"",remark:""}', create_at timestamp default CURRENT_TIMESTAMP not null comment '????????????', modified_at timestamp default CURRENT_TIMESTAMP not null comment '????????????' )' no viable alternative at input 'create table flink_ui_fat.t_flink_configuration(\n id bigint unsigned primary key not null auto_increment comment '??????ID',\n config_key varchar(128) not null comment '??????Key????????????Flink??????????????????Zeppelin??????',\n default_value varchar(512) null comment '??????????????????????????????',\n config_type varchar(16) not null comment '?????????????????????Zeppelin???interpreter?????????interpreter??????FlinkSQL???Configuration?????????sql??????FlinkTable???Connector?????????connector???',\n optional' at io.debezium.antlr.ParsingErrorListener.syntaxError(ParsingErrorListener.java:43) at org.antlr.v4.runtime.ProxyErrorListener.syntaxError(ProxyErrorListener.java:41) at org.antlr.v4.runtime.Parser.notifyErrorListeners(Parser.java:544) at org.antlr.v4.runtime.DefaultErrorStrategy.reportNoViableAlternative(DefaultErrorStrategy.java:310) at org.antlr.v4.runtime.DefaultErrorStrategy.reportError(DefaultErrorStrategy.java:136) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:1169) at io.debezium.ddl.parser.mysql.generated.MySqlParser.root(MySqlParser.java:897) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:72) at io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.parseTree(MySqlAntlrDdlParser.java:45) at io.debezium.antlr.AntlrDdlParser.parse(AntlrDdlParser.java:82) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseDdl(MySqlDatabaseSchema.java:213) at io.debezium.connector.mysql.MySqlDatabaseSchema.parseStreamingDdl(MySqlDatabaseSchema.java:200) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:574) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:352) ... 5 more Caused by: org.antlr.v4.runtime.NoViableAltException at org.antlr.v4.runtime.atn.ParserATNSimulator.noViableAlt(ParserATNSimulator.java:2026) at org.antlr.v4.runtime.atn.ParserATNSimulator.execATN(ParserATNSimulator.java:467) at org.antlr.v4.runtime.atn.ParserATNSimulator.adaptivePredict(ParserATNSimulator.java:393) at io.debezium.ddl.parser.mysql.generated.MySqlParser.sqlStatements(MySqlParser.java:971) ... 13 more 2021-09-30 08:01:20,365 INFO || Stopping down connector [io.debezium.connector.common.BaseSourceTask] 2021-09-30 08:01:20,393 INFO MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|streaming Finished streaming [io.debezium.pipeline.ChangeEventSourceCoordinator] 2021-09-30 08:01:20,393 INFO MySQL|debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306|binlog Stopped reading binlog after 0 events, no new offset was recorded [io.debezium.connector.mysql.MySqlStreamingChangeEventSource] 2021-09-30 08:01:20,407 INFO || Connection gracefully closed [io.debezium.jdbc.JdbcConnection] 2021-09-30 08:01:20,408 INFO || [Producer clientId=debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2021-09-30 08:01:20,410 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2021-09-30 08:01:20,410 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics] 2021-09-30 08:01:20,410 INFO || Metrics reporters closed [org.apache.kafka.common.metrics.Metrics] 2021-09-30 08:01:20,410 INFO || App info kafka.producer for debezium.sync.sr_dev_mysql_master_1_sr_cvte_cn_3306-dbhistory unregistered [org.apache.kafka.common.utils.AppInfoParser] 2021-09-30 08:01:20,410 INFO || [Producer clientId=connector-producer-debezium_sync_mysql_source_connector_sr_dev_mysql_master_1_sr_cvte_cn_3306-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [org.apache.kafka.clients.producer.KafkaProducer] 2021-09-30 08:01:20,413 INFO || Metrics scheduler closed [org.apache.kafka.common.metrics.Metrics] 2021-09-30 08:01:20,413 INFO || Closing reporter org.apache.kafka.common.metrics.JmxReporter [org.apache.kafka.common.metrics.Metrics]