[ https://issues.apache.org/jira/browse/FLINK-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Hueske closed FLINK-2874. -------------------------------- Resolution: Fixed Fix Version/s: 0.10 0.9 Fixed for 0.9 with ab694a3b22a88bfc5e911eae0c1e313073b6fd57 Fixed for 0.10 with c72eff4af8ef1f9fc36344f1ff52233bdc15e528 Fixed on master with cd7ed8e38c0d0e1313f5759e7bf34e0904972c6e > Certain Avro generated getters/setters not recognized > ----------------------------------------------------- > > Key: FLINK-2874 > URL: https://issues.apache.org/jira/browse/FLINK-2874 > Project: Flink > Issue Type: Bug > Components: Core > Affects Versions: 0.9.1, 0.9.0, 0.10 > Reporter: Ulf Karlsson > Priority: Minor > Fix For: 0.9, 0.10 > > Original Estimate: 2h > Remaining Estimate: 2h > > For Avro schemas where value null is not allowed, the field is unboxed e.g. > int but the getter/setter methods provide the boxed Integer as interface: > {code} > { > "fields": [ > { > "type": "double", > "name": "time" > }, > } > {code} > This results in Java > {code} > private double time; > public java.lang.Double getTime() { > return time; > } > public void setTime(java.lang.Double value) { > this.time = value; > } > {code} > There is also a problem when there is an underscore in the Avro schema, e.g.: > {code} > { > "default": null, > "type": [ > "null", > "long" > ], > "name": "conn_id" > }, > {code} > This results in Java: > {code} > private java.lang.Long conn_id; > public java.lang.Long getConnId() { > return conn_id; > } > public void setConnId(java.lang.Long value) { > this.conn_id = value; > } > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)