Flink SQL使用Tumble窗口函数报NoSuchMethodError functions/AggregateFunction 异常

[18293503878]

大家使用Flink SQL的tumble函数时，将结果表转换为流，报如下错误的异常吗
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.streaming.api.datastream.WindowedStream.aggregate(Lorg/apache/flink/api/common/functions/AggregateFunction;Lorg/apache/flink/streaming/api/functions/windowing/WindowFunction;Lorg/apache/flink/api/common/typeinfo/TypeInformation;Lorg/apache/flink/api/common/typeinfo/TypeInformation;Lorg/apache/flink/api/common/typeinfo/TypeInformation;)Lorg/apache/flink/streaming/api/datastream/SingleOutputStreamOperator;
at org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate.translateToPlan(DataStreamGroupWindowAggregate.scala:214)

[hailongwang]

Hi,
   你的 Flink 版本是哪个呢。从报错来看你在用 legacy planner，可以使用 blink planner 试试。

Best,
Hailong
在 2020-12-03 10:02:08，"18293503878" <[hidden email]> 写道：
>大家使用Flink SQL的tumble函数时，将结果表转换为流，报如下错误的异常吗
>Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.streaming.api.datastream.WindowedStream.aggregate(Lorg/apache/flink/api/common/functions/AggregateFunction;Lorg/apache/flink/streaming/api/functions/windowing/WindowFunction;Lorg/apache/flink/api/common/typeinfo/TypeInformation;Lorg/apache/flink/api/common/typeinfo/TypeInformation;Lorg/apache/flink/api/common/typeinfo/TypeInformation;)Lorg/apache/flink/streaming/api/datastream/SingleOutputStreamOperator;
>at org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate.translateToPlan(DataStreamGroupWindowAggregate.scala:214)

[JasonLee]

hi

从报错信息看应该jar包冲突了,可以贴一下相关的依赖包吗



-----
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/