[jira] [Created] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-2690) CsvInputFormat cannot find the field of derived POJO class

Shang Yuanchun (Jira)
Chiwan Park created FLINK-2690:
----------------------------------

             Summary: CsvInputFormat cannot find the field of derived POJO class
                 Key: FLINK-2690
                 URL: https://issues.apache.org/jira/browse/FLINK-2690
             Project: Flink
          Issue Type: Bug
          Components: Java API, Scala API
    Affects Versions: 0.10
            Reporter: Chiwan Park
            Assignee: Chiwan Park


An user report {{CsvInputFormat}} cannot find the field of derived POJO class. (http://mail-archives.apache.org/mod_mbox/flink-user/201509.mbox/%3cCAJ54yvi6CbLdN7cYpey+xe8a5A_J1-6Tnx1wm1Eb63gVnQd16w@...%3e)

The reason of the bug is that {{CsvInputFormat}} uses {{getDeclaredField}} method without scanning base classes to find the field. When {{CsvInputFormat}} was wrote, {{TypeInformation}} cannot be serialized. So we needed to initialize {{TypeInformation}} in {{open}} method manually. Some mistakes in initializing cause this bug.

After FLINK-2637 is merged, we can serialize {{TypeInformation}} and don't need to create field objects in {{CsvInputFormat}}.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)