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.
Read More:
- Flink Error: is not serializable. The object probably contains or references non serializable fields.
- [How to Fix]No executorfactory found to execute the application
- [Solved] Java.lang.BootstrapMethodError: call site initialization exception
- How to Solve Flynk Task Java verifyerror 209 error
- [ERROR] Failed to execute goal on project simple-project: Could not resolve dependencies for project
- [Solved] org.apache.flink.client.program.ProgramInvocationException: The main method caused an error
- [Solved] The main method caused an error: Could not deploy Yarn job cluster.
- How to Solve Flick operate Error: not serialized
- [Solved] Flink1.12 integrate Hadoop 3.X error: java.lang.RuntimeException…
- [Solved] Scala error: type mismatch; found : java.util.List[?0] required: java.util.List[B]
- Conversion of two data types in Java
- [Solved] Specified key was too long; max key length is 767 bytes
- [Solved] write javaBean error, fastjson version 1.2.76, class org.apache.flink.table.data.binary
- [Solved] Sqoop Error: ERROR tool.ImportTool: Import failed: java.io.IOException
- Spring integrated HBase error [How to Solve]
- [Solved] Springboot Project Start Error: An attempt was made to call the method com.google.common.collect.Multimaps.asMap
- [Solved] Mybatis Error: Cause: org.apache.ibatis.builder.BuilderException: Error creating document instance.
- [Solved] Mapreducer Class Conversion error: java.lang.ClassCastException
- Feign call Error: duplicate name [How to Solve]