Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-9556

Scala TypeAnalyzer does not consider ResultTypeQueryable

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: API / Scala
    • Labels:
      None

      Description

      Scala's TypeAnalyzer does not consider the ResultTypeQueryable interface. This means that type information that has been specified manually is ignored in many cases.

      For example:

      val myConsumer: FlinkKafkaConsumer010[Row] = new FlinkKafkaConsumer010(topics, new MyDeserializationSchema(jsonSchema), properties)
 val inputStream: DataStream[Row] = env.addSource(myConsumer)

      The row type is always generic even though a type information has been specified in the DeserializationSchema.

        Attachments

          Activity

            People

            • Assignee:
              twalthr Timo Walther
              Reporter:
              twalthr Timo Walther
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: