flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Benchao Li <libenc...@gmail.com>
Subject Re: Re: image
Date Fri, 14 Feb 2020 09:55:51 GMT
我理解应该只需要flink-sql-connector-kafka_2.11-1.10.0.jar这个包就可以了,
flink-connector-kafka_2.11-1.10.0.jar这个包不需要放进去的。

潘明文 <panminwen@163.com> 于2020年2月14日周五 下午5:50写道:

>
>
> 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" <libenchao@gmail.com> 写道:
> >明文,
> >
> >你的图片没有在邮件中显示出来。
> >你可以用第三方的图床来上传图片,或者直接以text的方式发送你的异常信息。
> >
> >
> >潘明文 <panminwen@163.com> 于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: libenchao@gmail.com; libenchao@pku.edu.cn
>


-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message