Re: Flink job消费kafka 失败,无法拿到offset值

2021-04-23 文章 liang zhao
一个查Flink与集群B的网络连通性,一个是查集群B本身服务状态,比如是所有topic都连不上还是某个topic连不上,是不是有节点挂掉了,另外一个再看看kafka的_offset_consumer是不是单节点正好挂了,如果是单个topic看分区问题。 > 2021年4月23日 18:45,wysstar...@163.com 写道: > > 应该是flink 连接不上kafka ,建议往docker 的网络设置上找找看问题 > > 发自我的iPhone > >> 在 2021年4月23日,下午12:56,Qingsheng Ren 写道: >> >> 你好 Jacob, >>

Re: flink 1.10.2 Unknown operation 108

2021-02-28 文章 liang zhao
没有图,重新发下吧,用图床 > 2021年3月1日 14:46,xushanshan <1337220...@qq.com> 写道: > > flink 1.10.2 使用sql编写的任务,凌晨总是报如下所示的错误,但是任务没停数据正常,请问是什么原因? > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/

Re: test

2020-12-27 文章 liang zhao
请不要发送这些无意义的邮件 > 2020年12月27日 23:19,蒋德祥 写道: > >

Re: flink clickhouse connector

2020-12-17 文章 liang zhao
我使用的是第三方的驱动,clickhouse-native-jdbc,通过JDBC的方式。 > 2020年12月17日 18:41,magichuang 写道: > > hi想问一下有小伙伴使用flink > 往clickhouse里面写数据嘛?我是使用的https://help.aliyun.com/document_detail/185696.html?spm=a2c4g.11186623.6.606.6222693bubxXzX > 这个flink-connector,但是运行报错了: > > Caused by: java.io.IOException: unab