[FLINK-9557] Parse 'integer' type as BigDecimal

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.6.0
• Labels: pull-request-available
• Assignee: Timo Walther
• Reporter: Dominik Wosiński
• Created: 08/Jun/18 11:09
• Updated: 26/Jun/18 12:54
• Resolved: 26/Jun/18 12:53

Description

Currently,

FlinkTypeFactory.typeInfoToSqlTypeName(typeInfo: TypeInformation[_]) 

does not support BigInteger, and since this is default type returned by

JsonSchemaConverter.convert(String schema)

for all fields with type: integer this can be problematic for anyone who wants to force values to be of type Integer or Long. 
In 1.5.0 it is possible to register stream with BigInteger as a type, but using this field in __SELECT query will cause it to fail due to problem above.

 

Issue Links

• links to: GitHub Pull Request #6153