一、 报错:[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;
待解决
1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。 |