[jira] [Updated] (FLINK-20583) Support to define the data range of decimal types in datagen table source connector

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

     [ https://issues.apache.org/jira/browse/FLINK-20583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jark Wu updated FLINK-20583:
----------------------------
    Fix Version/s:     (was: 1.12.1)

> Support to define the data range of decimal types in datagen table source connector
> -----------------------------------------------------------------------------------
>
>                 Key: FLINK-20583
>                 URL: https://issues.apache.org/jira/browse/FLINK-20583
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table SQL / Runtime
>    Affects Versions: 1.12.0
>         Environment: Flink 1.12.0
>            Reporter: tonychen0716
>            Priority: Minor
>
>  
> {code:java}
> – FLink SQL
>  CREATE TABLE datagen
>  (
>  lon DECIMAL(38, 18) COMMENT 'lon',
>  lat DECIMAL(38, 18) COMMENT 'lat'
>  )
>  WITH (
>  'connector' = 'datagen',
>  'rows-per-second' = '10',
>  'fields.lon.kind' = 'random',
>  'fields.lon.min' = '116.40',
>  'fields.lon.max' = '116.41',
>  'fields.lat.kind' = 'random',
>  'fields.lat.min' = '39.894454',
>  'fields.lat.max' = '39.90'
>  );
> CREATE TABLE sink
>  (
>  lon DECIMAL(38, 18),
>  lat DECIMAL(38, 18)
>  )
>  WITH (
>  'connector' = 'print'
>  );
> INSERT INTO sink
>  SELECT lon,
>  lat
>  from datagen;
> {code}
>  
> It give exception:
>  
> {code:java}
> Table options are:
> 'connector'='datagen'
> 'fields.lat.kind'='random'
> 'fields.lat.max'='39.90'
> 'fields.lat.min'='39.894454'
> 'fields.lon.kind'='random'
> 'fields.lon.max'='116.41'
> 'fields.lon.min'='116.40'
> 'rows-per-second'='10'
> Unsupported options found for connector 'datagen'.
> Unsupported options:
> fields.lat.max
> fields.lat.min
> fields.lon.max
> fields.lon.min
> Supported options:
> connector
> fields.lat.kind
> fields.lon.kind
> number-of-rows
> rows-per-second
> INSERT INTO sink
> SELECT lon,
>  lat
> from datagen 
> {code}
>  



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