report errors

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

Solution:

Generally, curly braces are omitted:

OutputTag<ApacheLogEvent> lateTag = new OutputTag<ApacheLogEvent>("late-tag");

Replace with:

OutputTag<ApacheLogEvent> lateTag = new OutputTag<ApacheLogEvent>("late-tag"){};

Places that are easy to ignore.