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

Mention Scala type fallacies for queryable state client serializers

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.2.1, 1.3.0
    • Component/s: Documentation
    • Labels:
      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

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

              Dates

              • Created:
                Updated:
                Resolved: