[jira] [Created] (FLINK-15158) Why convert integer to bigdecimal for formart-json when kafka is used

["hehuiyuan (Jira)" <ji...@apache.org>]

hehuiyuan created FLINK-15158:
---------------------------------

             Summary: Why convert integer to bigdecimal for formart-json when kafka is used
                 Key: FLINK-15158
                 URL: https://issues.apache.org/jira/browse/FLINK-15158
             Project: Flink
          Issue Type: Wish
          Components: Formats (JSON, Avro, Parquet, ORC, SequenceFile)
            Reporter: hehuiyuan


For example , 

I have a table  `table1` :

root
 |-- name: STRING
 |-- age: INT
 |-- sex: STRING

 

then , I want to `insert into kafka select * form table1` :

jsonschame: 

{type:'object',properties:\{name: { type: 'string' },age: \{ type: 'integer' },sex: \{ type: 'string' }}}

 

```

descriptor.withFormat(new Json().jsonSchema(jsonSchema)).withSchema(schema);

```

 

Exception in thread "main" org.apache.flink.table.api.ValidationException: Field types of query result and registered TableSink [sink_example2] do not match.Exception in thread "main" org.apache.flink.table.api.ValidationException: Field types of query result and registered TableSink [sink_example2] do not match.

*Query result schema: [name: String, age: Integer, sex: String]*

*TableSink schema:    [name: String, age: BigDecimal, sex: String]* at org.apache.flink.table.sinks.TableSinkUtils$.validateSink(TableSinkUtils.scala:65) at org.apache.flink.table.planner.StreamPlanner$$anonfun$2.apply(StreamPlanner.scala:156) at org.apache.flink.table.planner.StreamPlanner$$anonfun$2.apply(StreamPlanner.scala:155) at scala.Option.map(Option.scala:146) 

 

I know that the type of integer in the jsonschema is convert to BigDecimal .But for the above scenario, does this have to be forced to be decimal?

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)