一、 报错：[ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'kafka' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

Available factory identifiers are:

blackhole datagen filesystem print

解决：flink-table-common-1.12.2.jar 放到lib路径

二、 报错：[ERROR] Could not execute SQL statement. Reason: java.lang.ClassNotFoundException: org.apache.kafka.common.serialization.ByteArrayDeserializer

解决：kafka-clients-2.0.0.jar 放到lib路径

三、 报错：[ERROR] Could not execute SQL statement. Reason: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.

解决：

四、 报错：[ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.api.ValidationException: Unsupported options found for connector 'upsert-kafka'.

Unsupported options:

format scan.startup.mode

Supported options:

connector key.fields-prefix key.format key.json.fail-on-missing-field key.json.ignore-parse-errors key.json.map-null-key.literal key.json.map-null-key.mode key.json.timestamp-format.standard properties.bootstrap.servers properties.group.id property-version sink.parallelism topic value.fields-include value.format value.json.fail-on-missing-field value.json.ignore-parse-errors value.json.map-null-key.literal value.json.map-null-key.mode value.json.timestamp-format.standard 解决：不支持

五、 问题：[ERROR] Could not execute SQL statement. Reason: java.lang.NoSuchMethodError: org.apache.flink.formats.json.JsonOptions.getTimestampFormat(Lorg/apache/flink/configuration/ReadableConfig;)Lorg/apache/flink/formats/common/TimestampFormat;

待解决