select * from mykafka1
错误信息:
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoSuchMethodError:
org.apache.flink.streaming.connectors.kafka.internals.metrics.KafkaMetricWrapper.<init>(Lorg/apache/kafka/common/Metric;)V
在 2020-02-14 17:43:16，"Benchao Li" <[email protected]> 写道：
>明文，
>
>你的图片没有在邮件中显示出来。
>你可以用第三方的图床来上传图片，或者直接以text的方式发送你的异常信息。
>
>
>潘明文 <[email protected]> 于2020年2月14日周五 下午5:31写道：
>
>>
>>
>> CREATE TABLE mykafka1(name String) WITH (
>> 'connector.type' = 'kafka',
>> 'connector.version' = 'universal',
>> 'connector.topic' = 'mysql_binlog',
>> 'connector.properties.zookeeper.connect' = 'masternode1:2181',
>> 'connector.properties.bootstrap.servers' = 'masternode1:9092',
>> 'format.type' = 'csv',
>> 'update-mode' = 'append'
>> );
>>
>>
>> 出现下面错误，没有方法，是版本不对吗？我用的是flink-sql-connector-kafka_2.11-1.10.0.jar
>> flink-connector-kafka_2.11-1.10.0.jar
>>
>>
>>
>>
>>
>
>
>--
>
>Benchao Li
>School of Electronics Engineering and Computer Science, Peking University
>Tel:+86-15650713730
>Email: [email protected]; [email protected]
