The generic type parameters of ‘Tuple2‘ are missing. In many cases lambda methods don‘t provide

电玩女神 2023-10-06 21:23 21阅读 0赞

#### 前言 ####

想在使用datastream api 开发的时候，对于多个字段开窗的时候，刚开始是逐个排序，但是影响性能。所以想把两个字段一起来排序，就遇到以下问题。

###### 问题描述 ######

Exception in thread "main" org.apache.flink.api.common.functions.InvalidTypesException: 
    The generic type parameters of 'Tuple2' are missing. 
    In many cases lambda methods don't provide enough information 
    for automatic type extraction when Java generics are involved.
    An easy workaround is to use an (anonymous) class instead that implements the '
    org.apache.flink.api.java.functions.KeySelector' interface.
    Otherwise the type has to be specified explicitly using type information.
    	at org.apache.flink.api.java.typeutils.TypeExtractionUtils.validateLambdaType(TypeExtractionUtils.java:371)
    	at org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:565)
    	at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:412)
    	at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:403)
    	at org.apache.flink.streaming.api.datastream.KeyedStream.<init>(KeyedStream.java:116)
    	at org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:293)

![在这里插入图片描述][watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN56ev6Les5q2l77yM5peg5Lul6Ie05Y2D6YeM_size_20_color_FFFFFF_t_70_g_se_x_16]

###### 解决办法： ######

// 避免flink java的泛型擦除 写法
            SingleOutputStreamOperator<Snapshot> operator = singleOutputStreamOperator.keyBy(new KeySelector<Snapshot, Tuple2<String, String>>() {
        
                @Override
                public Tuple2<String, String> getKey(Snapshot snapshot) throws Exception {
        
                    return Tuple2.of(snapshot.getDateTime(), snapshot.getHsSecurityId());
                }
            }).flatMap(new SnapshotProcessFunction());

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5LiN56ev6Les5q2l77yM5peg5Lul6Ie05Y2D6YeM_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/29b026bca21a4cefa124e320f3005313.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5LiN56ev6Les5q2l77yM5peg5Lul6Ie05Y2D6YeM,size_20,color_FFFFFF,t_70,g_se,x_16

The generic type parameters of ‘Tuple2‘ are missing. In many cases lambda methods don‘t provide

发表评论取消回复

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

相关阅读

相关 SpringBoot:错误Missing URI template variable ‘userId‘ for method parameter of type String

相关 SpringBoot:错误Missing URI template variable ‘userId‘ for method parameter of type String

相关 The generic type parameters of ‘Tuple2‘ are missing. In many cases lambda methods don‘t provide

相关解决Parameter 0 of method modifyRequestBodyGatewayFilterFactory in org.springfra。。。

相关 feign Method has too many Body parameters

相关 Types cannot be provided in put mapping requests, unless the include_type_name parameter is set to t

相关错误：Parameter 0 of method sqlSessionFactory in MyBatisConfig required a bean of type ‘javax.sql.DataS

相关 SonarLint: Provide the parametrized type for this generic.

相关 TypeError: view must be a callable or a list/tuple in the case of include().解决办法

相关 redis配置文件报错 Does the parameter type of the setter match the return type of the getter?