Hi，吴志勇
你的SQL表定义应该没问题，出问题的地方 现在flink的 json format 遵循
RFC3399标准[1]，其识别的timestamp的格式是:'yyyy-MM-dd'T'HH:mm:ss.SSS’Z', 暂不支持long解析为
timestamp，你可以在输出到kafka时将timestamp转换成该格式：
DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
Date date = new Date(System.currentTimeMillis());
String jsonSchemaDate = dateFormat.format(date);
//{"id":5,"price":40,"timestamp”:”2020-03-24T18:23:38.123Z","type":"math"}
这个问题社区已经有issue [2]在跟进了，该issue会支持long转timestamp。
另外，如果是中文提问请发user-zh邮件列表，user邮件列表请用英语哈^_^
Best,
Leonard
[1]https://json-schema.org/understanding-json-schema/reference/string.html#dates-and-times
<https://json-schema.org/understanding-json-schema/reference/string.html#dates-and-times>
[2]https://issues.apache.org/jira/browse/FLINK-16725
<https://issues.apache.org/jira/browse/FLINK-16725>
> 在 2020年3月23日，15:35，吴志勇 <[email protected]> 写道：
>
> 如题：
> 我向kafka中输出了json格式的数据
> {"id":5,"price":40,"timestamp":1584942626828,"type":"math"}
> {"id":2,"price":70,"timestamp":1584942629638,"type":"math"}
> {"id":2,"price":70,"timestamp":1584942634951,"type":"math"}
> ....
> 其中timestamp字段是13位时间戳，对应的SQL表中应该怎么处理成时间格式呢？
> - name: bookpojo
> type: source-table
> connector:
> property-version: 1
> type: kafka
> version: "universal"
> topic: pojosource
> startup-mode: earliest-offset
> properties:
> zookeeper.connect: localhost:2181
> bootstrap.servers: localhost:9092
> group.id: testGroup
> format:
> property-version: 1
> type: json
> schema: "ROW<id INT, type STRING, price INT, timestamp TIMESTAMP>"
> schema:
> - name: id
> data-type: INT
> - name: type
> data-type: STRING
> - name: price
> data-type: INT
> - name: timestamp
> data-type: TIMESTAMP(3)
>
> 上述配置，好像有问题。
>
> 我在官网中找到这样一句说明：
> 字符串和时间类型：时间类型必须根据Java SQL时间格式进行格式化，并以毫秒为单位。例如：
> 2018-01-01日期，20:43:59时间和2018-01-01 20:43:59.999时间戳。
> 时间一定得是字符串类型且带毫秒吗？
>
> 谢谢。
>
