Flink sink任务报错： could not find implicit value for evidence parameter of type org.apache.flink.api...

小鱼儿 2022-09-15 11:51 290阅读 0赞

如图：scala代码开发flink任务，sink到clickhouse时启动报错！

报错一：

could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[org.apache.flink.types.Row]
val dataStream = bsTableEnv.toAppendStream[Row](result).map(line => {

报错二：

could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[Row]

watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5aSn5pWw5o2u5p625p6E5biIUG9ueQ_size_20_color_FFFFFF_t_70_g_se_x_16

原因：没有导入隐式转换

解决：导入隐式转换（注意：在引用之前导入！！！）

watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5aSn5pWw5o2u5p625p6E5biIUG9ueQ_size_20_color_FFFFFF_t_70_g_se_x_16 1

发表评论

表情：
评论列表 （有 0 条评论，290人围观）

还没有评论，来说两句吧...

相关阅读