关于flink中的OutputTag报错
作者:互联网
报错
Exception in thread "main" org.apache.flink.api.common.functions.InvalidTypesException: Could not determine TypeInformation for the OutputTag type. The most common reason is forgetting to make the OutputTag an anonymous inner class. It is also not possible to use generic type variables with OutputTags, such as 'Tuple2<A, B>'.
Caused by: org.apache.flink.api.common.functions.InvalidTypesException: The types of the interface org.apache.flink.util.OutputTag could not be inferred. Support for synthetic interfaces, lambdas, and generic or raw types is limited at this point
解决
一般是少写了花括号:
OutputTag<ApacheLogEvent> lateTag = new OutputTag<ApacheLogEvent>("late-tag");
改为:
OutputTag<ApacheLogEvent> lateTag = new OutputTag<ApacheLogEvent>("late-tag"){};
比较容易忽略的地方。
标签:OutputTag,flink,报错,common,apache,org 来源: https://blog.csdn.net/qq_29494693/article/details/122409441