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.3.0, 1.2.1
    • 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)
      

        Activity

        Hide
        uce Ufuk Celebi added a comment -

        Fixed in 15bb424 (release-1.2), 8e1775a (master).

        Show
        uce Ufuk Celebi added a comment - Fixed in 15bb424 (release-1.2), 8e1775a (master).

          People

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

            Dates

            • Created:
              Updated:
              Resolved:

              Development