org.apache.flink.api.common.functions.InvalidTypesException: The return type of function 'retrieve(ReplyGraph.java:33)' could not be determined automatically, due to type erasure. You can give type information hints by using the returns(...) method on the result of the transformation call, or by letting your function implement the 'ResultTypeQueryable' interface.

Stack Overflow | hasan | 3 months ago
  1. 0

    Flink does not run my appliation due to invalidtypesexception when using java8 lambdas

    Stack Overflow | 3 months ago | hasan
    org.apache.flink.api.common.functions.InvalidTypesException: The return type of function 'retrieve(ReplyGraph.java:33)' could not be determined automatically, due to type erasure. You can give type information hints by using the returns(...) method on the result of the transformation call, or by letting your function implement the 'ResultTypeQueryable' interface.
  2. 0

    Creating a graph using a mapper function does not work

    GitHub | 2 years ago | cebe
    org.apache.flink.client.program.ProgramInvocationException: The main method caused an error.
  3. 0

    GitHub comment 1#212887850

    GitHub | 7 months ago | c-val
    org.apache.flink.api.common.functions.InvalidTypesException: The generic type parameters of 'Map' are missing. It seems that your compiler has not stored them into the .class file. Currently, only the Eclipse JDT compiler preserves the type information necessary to use the lambdas feature type-safely. See the documentation for more information about how to compile jobs containing lambda expressions.
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    GitHub comment 46#68704608

    GitHub | 2 years ago | StephanEwen
    org.apache.flink.api.common.functions.InvalidTypesException: Type of TypeVariable 'K' in 'class flink.graphs.library.SingleSourceShortestPaths$InitVerticesMapper' could not be determined. This is most likely a type erasure problem. The type extraction currently supports types with generic variables only in cases where all variables in the return type can be deduced from the input type(s).
  6. 0

    Type issues with mapVertices

    GitHub | 2 years ago | vasia
    org.apache.flink.api.common.functions.InvalidTypesException: Type of TypeVariable 'K' in 'class flink.graphs.library.SingleSourceShortestPaths$InitVerticesMapper' could not be determined. This is most likely a type erasure problem. The type extraction currently supports types with generic variables only in cases where all variables in the return type can be deduced from the input type(s).

    Not finding the right solution?
    Take a tour to get the most out of Samebug.

    Tired of useless tips?

    Automated exception search integrated into your IDE

    Root Cause Analysis

    1. org.apache.flink.api.common.functions.InvalidTypesException

      The generic type parameters of 'Tuple3' are missing. It seems that your compiler has not stored them into the .class file. Currently, only the Eclipse JDT compiler preserves the type information necessary to use the lambdas feature type-safely. See the documentation for more information about how to compile jobs containing lambda expressions.

      at org.apache.flink.api.java.typeutils.TypeExtractor.validateLambdaGenericParameter()
    2. flink-java
      DataSet.map
      1. org.apache.flink.api.java.typeutils.TypeExtractor.validateLambdaGenericParameter(TypeExtractor.java:1316)
      2. org.apache.flink.api.java.typeutils.TypeExtractor.validateLambdaGenericParameters(TypeExtractor.java:1302)
      3. org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:346)
      4. org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:304)
      5. org.apache.flink.api.java.typeutils.TypeExtractor.getMapReturnTypes(TypeExtractor.java:119)
      6. org.apache.flink.api.java.DataSet.map(DataSet.java:215)
      6 frames
    3. org.apache.flink
      ReplyGraph.main
      1. org.apache.flink.quickstart.exercise2.ReplyGraph.retrieve(ReplyGraph.java:33)
      2. org.apache.flink.quickstart.exercise2.ReplyGraph.main(ReplyGraph.java:56)
      2 frames
    4. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:498)
      4 frames
    5. IDEA
      AppMain.main
      1. com.intellij.rt.execution.application.AppMain.main(AppMain.java:147)
      1 frame