Flink-1.9.1

[somnussuy]

针对于使用 SQL查询，select current_timestamp,creaetTime from sourceTable ;其中 createTime 注册成 SQL_TIMESTMAP 类型
问题描述：
无论是流中的原有数据 createTime,还是 current_time 函数
打印的结果都出现格式的问题
2019-11-06T11:01:24.047,2019-11-06T18:53:54
请问：
如何避免格式中 T 的出现

针对于上封邮件进行补充:
做了类型检测：flink 1.9.1 对于执行完SQL之后的类型，date 使用 java.time.LocalDate；timestamp 使用 java.time.LocalDateTime
而1.7.2版本是 date 使用 java.sql.date；timestamp 使用 java.sql.timestamp
请问：
是出于什么考虑改变这个策略的？

 


 

[Wenlong Lyu]

想输出指定格式可以试试用DATE_FORMAT函数做一下格式化，转成string

On Wed, 6 Nov 2019 at 19:36, [hidden email] <[hidden email]> wrote:

> 针对于使用 SQL查询，select current_timestamp,creaetTime from sourceTable ;其中
> createTime 注册成 SQL_TIMESTMAP 类型
> 问题描述：
> 无论是流中的原有数据 createTime,还是 current_time 函数
> 打印的结果都出现格式的问题
> 2019-11-06T11:01:24.047,2019-11-06T18:53:54
> 请问：
> 如何避免格式中 T 的出现
>
> 针对于上封邮件进行补充:
> 做了类型检测：flink 1.9.1 对于执行完SQL之后的类型，date 使用 java.time.LocalDate；timestamp 使用
> java.time.LocalDateTime
> 而1.7.2版本是 date 使用 java.sql.date；timestamp 使用 java.sql.timestamp
> 请问：
> 是出于什么考虑改变这个策略的？
>
>
>
>
>
>

[somnussuy]

输出指定格式是没问题的，只是很疑惑 blink 和 flink 之间的选择差异的需求点是什么



[hidden email]
 
From: wenlong.lwl
Date: 2019-11-07 10:20
To: user-zh
Subject: Re: Flink-1.9.1
想输出指定格式可以试试用DATE_FORMAT函数做一下格式化，转成string
 
On Wed, 6 Nov 2019 at 19:36, [hidden email] <[hidden email]> wrote:
 

> 针对于使用 SQL查询，select current_timestamp,creaetTime from sourceTable ;其中
> createTime 注册成 SQL_TIMESTMAP 类型
> 问题描述：
> 无论是流中的原有数据 createTime,还是 current_time 函数
> 打印的结果都出现格式的问题
> 2019-11-06T11:01:24.047,2019-11-06T18:53:54
> 请问：
> 如何避免格式中 T 的出现
>
> 针对于上封邮件进行补充:
> 做了类型检测：flink 1.9.1 对于执行完SQL之后的类型，date 使用 java.time.LocalDate；timestamp 使用
> java.time.LocalDateTime
> 而1.7.2版本是 date 使用 java.sql.date；timestamp 使用 java.sql.timestamp
> 请问：
> 是出于什么考虑改变这个策略的？
>
>
>
>
>
>