flinkcdc2.3.0对接postgre这个报错大家有遇到过么？2023-04-10 06:06

flinkcdc2.3.0对接postgre这个报错大家有遇到过么？2023-04-10 06:06:38,129 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: TableSourceScan(table=[[default_catalog, default_database, products]], fields=[cum_id, secret_id, response_code, ecid, product_code, product_name, partner_secret_id, secret_id_type, product_ord_id, product_code_type, eboss_product_code, partner_product_code, request_refid, response_refid, response_msg, response, timeresp, id, request_time, response_time, name, mobile, cert_no, result, response_key, response_value, customer_req_time, customer_resp_time, partner_id]) -> DropUpdateBefore -> Calc(select=[cum_id, secret_id, response_code, ecid, product_code, product_name, partner_secret_id, secret_id_type, product_ord_id, product_code_type, eboss_product_code, partner_product_code, request_refid, response_refid, response_msg, response, timeresp, id, request_time, CAST(DATE_FORMAT(request_time, _UTF-16LE'yyyyMMddHH')) AS request_hour_time, CAST(DATE_FORMAT(request_time, _UTF-16LE'yyyyMMdd')) AS request_day_time, CAST(DATE_FORMAT(request_time, _UTF-16LE'yyyyMM')) AS request_month_time, CAST(DATE_FORMAT(request_time, _UTF-16LE'yyyy')) AS request_year_time, response_time, name, mobile, cert_no, result, response_key, response_value, customer_req_time, customer_resp_time, partner_id]) (1/1) (c4290cd3a02426892bab790950da1a3b) switched from RUNNING to FAILED on container_1671783510478_0035_01_000002 @ hyy-cdh-002 (dataPort=45806). com.ververica.cdc.connectors.shaded.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) ~[flink-sql-connector-mysql-cdc-2.3.0.jar:2.3.0] at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:168) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0] at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:40)