Mulan created FLINK-20170:
-----------------------------
Summary: json deserialize loses precision
Key: FLINK-20170
URL: https://issues.apache.org/jira/browse/FLINK-20170
Project: Flink
Issue Type: Improvement
Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile), Table
SQL / API
Reporter: Mulan
{code:java}
CREATE TABLE ods (
id BIGINT,
factor DECIMAL(38, 18)
) WITH (
'connector.type' = 'kafka',
'connector.version' = 'universal',
'connector.topic' = '_foo',
'connector.topic?' = '_foo',
'connector.properties.bootstrap.servers' = 'localhost:9092',
'connector.properties.group.id' = 'g',
'format.type' = 'json',
'update-mode' = 'append'
);
{code}
this following is input data.
{code:json}
{"id": 1, "factor": 799.929496989092949698}
{code}
this following is output data and loses precision.
{code:json}
1, 799.929496989093000000
{code}
{code:java}
public Row deserialize(byte[] message) throws IOException {
try {
final JsonNode root = objectMapper.readTree(message);
return (Row) runtimeConverter.convert(objectMapper,
root);
} catch (Throwable t) {
throw new IOException("Failed to deserialize JSON
object.", t);
}
}
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
