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

Flink complains when scala.Option is used inside POJO

    XMLWordPrintableJSON

Details

    Description

      According to the documentation, Flink has a specialized serializer for Option type. However, when an Option field is used inside a POJO, the following WARNING appears in TaskManagers' log.

       

      No fields detected for class scala.Option. Cannot be used as a PojoType. Will be handled as GenericType

      Attachments

        1. TypeInfomationTest.scala
          0.9 kB
          Truong Duc Kien

        Activity

          People

            Unassigned Unassigned
            kien_truong Truong Duc Kien
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: