报错

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"){};

比较容易忽略的地方。