Thanks Godfrey for the detailed explanation.
Youngwoo
2020년 8월 19일 (수) 오후 12:47, godfrey he 님이 작성:
> Hi Youngwoo,
>
> > 1. TIMESTAMP WITH LOCAL TIME ZONE
> Currently, SQL client uses legacy types for the collect sink, that means
> `TIMESTAMP
> WITH LOCAL TIME ZONE` is not supported.
> you can r
Hi Youngwoo,
> 1. TIMESTAMP WITH LOCAL TIME ZONE
Currently, SQL client uses legacy types for the collect sink, that
means `TIMESTAMP
WITH LOCAL TIME ZONE` is not supported.
you can refer to [1] to find the supported types, and there is a pr [2] to
fix this.
>2. TIMESTAMP(3) WITH LOCAL TIME ZONE
I
Hi Benchao,
I include ['json.timestamp-format.standard' = 'ISO-8601'] to table's DDL
but it does not work with slightly different errors:
1. TIMESTAMP WITH LOCAL TIME ZONE
Exception in thread "main"
org.apache.flink.table.client.SqlClientException: Unexpected exception.
This is a bug. Please con
Hi Youngwoo,
What version of Flink and Json Format are you using?
>From 1.11, we introduced `json.timestamp-format.standard` to declare the
timestamp format.
You can try `timestamp with local zone` data type with `ISO-8601` timestamp
format.
Youngwoo Kim (김영우) 于2020年8月15日周六 下午12:12写道：
> Hi,
>
Hi,
I'm trying to create a table using Flink SQL to query from a Kafka topic.
Messages from Kafka look like following:
(snip)
"svc_mgmt_num":"7749b6a7e17127d43431e21b94f4eb0c116..."
"log_ymdt":"2020-08-15T02:01:33.968Z"
"snapshot_dt":"2020-08-13"
"network_type":"LTE"
I'd like to make the column
