Cannot resolve overloaded method 'aggregate'

Flink在窗口中使用aggregate聚合函数时，提示 Cannot resolve overloaded method 'aggregate'错误

这里可能有2个地方引起的问题：

1. 导入WindowFunction包问题：

下面包是错误的，因为我们是基于scala的开发。

import org.apache.flink.streaming.api.functions.windowing.WindowFunction

应该使用：

import org.apache.flink.streaming.api.scala.function.WindowFunction

2. KeyBy中的类型和自定义的WindowFunction中的key类型不一致。

这种一般看提示不太明显：

修改类型相同后即可。

Cannot resolve overloaded method 'aggregate'相关推荐

spark报错：Cannot resolve overloaded method ‘agg‘
报错信息为: Cannot resolve overloaded method 'agg' 解决办法: 导入包 import org.apache.spark.sql.functions._
Cannot resolve overloaded method 'addsink
报错源 def f1(x:String){ val a=x.split(",") val b=2000-(a(1).split("-")(0)).toInt v ...
Cannot resolve overloaded method ‘createDataFrame‘
在spark中利用自己定义schema的方式创建dataframe遇到了rt所示的错误原因分析: 首先定义rdd val dCom = spark.read.orc(pth1+"/2020 ...
Scala报错：error: overloaded method value logInfo with alternatives
1.背景写了这么一段代码 object JdbcSink extends Logging {def writeToJdbc(df:DataFrame, sink: StreamSink, drive ...
Structured Streaming报错记录：Overloaded method foreachBatch with alternatives
Structured Streaming报错记录:Overloaded method foreachBatch with alternatives [文章目录] Structured Streamin ...
Overloaded method foreachBatch with alternatives
前言本文隶属于专栏<Spark异常问题汇总>,该专栏为笔者原创,引用请注明来源,不足和错误之处请在评论区帮忙指出,谢谢! 本专栏目录结构和参考文献请见 Spark异常问题汇总正文问题 ...
flink1.12 process方法报错 overloaded method value process with alternatives
报错 overloaded method value process with alternatives:[R](keyedProcessFunction: org.apache.flink.stre ...
Spark影评数据分析三
在上一篇我们已经学习了前五个需求如何实现,现在看看后五个. 需求六 package movie import org.apache.spark.rdd.RDD//求最喜欢看电影(影评次数最多)的那位女 ...
Ambiguous method overloading for method ****** 异常的解决办法
Ambiguous method overloading for method ****** 异常前言:关于该异常,我是在stackoverflow上(https://stackoverflow.c ...

Cannot resolve overloaded method 'aggregate'

Cannot resolve overloaded method 'aggregate'相关推荐

最新文章

热门文章