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

Mention Scala type fallacies for queryable state client serializers

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 1.2.1, 1.3.0
    • Documentation
    • None

    Description

      FLINK-5801 shows a very hard to debug issue when querying state from the Scala API that can result in serializer mismatches between the client and the job.

      We should mention that the type serializers should be created via the Scala macros.

      import org.apache.flink.streaming.api.scala._
      ...
      val keySerializer = createTypeInformation[Long].createSerializer(new ExecutionConfig)
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            uce Ufuk Celebi
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: