Hi,all:
我在zeppelin执行如下DDL和SQL，报如下错误：
DDL：
DROP TABLE IF EXISTS user_log ;
CREATE TABLE user_log (
user_id VARCHAR,
item_id VARCHAR,
category_id VARCHAR,
behavior VARCHAR,
ts TIMESTAMP
) WITH (
'connector.type' = 'kafka',
'connector.version' = 'universal',
'con
Hi Fei,
Kafka source/sink 不支持 TIMESTAMP(6) 类型，支持精度3，且现在 TIMESTAMP 不带精度默认是6，所以需要你将
DDL 声明中的 TIMESTAMP 改成 TIMESTAMP(3).
Beest,
Jark
On Sun, 23 Feb 2020 at 15:44, Fei Han
wrote:
>
> Hi,all:
>我在zeppelin执行如下DDL和SQL，报如下错误：
> DDL：
> DROP TABLE IF EXISTS user_log ;
> CREATE TABLE user_log (
>
项目需求要向 postgres 中插入数据，用 catalog 之后，插入数据貌似需要和数据库表定义完全一致，而且没找到只插入部分字段的写法
在时间转 TIMESTAMP(6) WITH LOCAL TIME ZONE 时报了错，这个格式是 postgres 中的时间戳定义
select cast(localtimestamp as TIMESTAMP(6) WITH LOCAL TIME ZONE);
有没有什么转换方法？或者只插入部分数据的方法？
报错信息：
Exception in thread "main" org.apache.flink.table.client.SqlClientException:
Unexpected exception. This is a bug. Please consider filing an issue.
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:213)
Caused by: org.apache.flink.table.api.TableException: Unsupported conversion
看报错信息，你并没有 insert into postgres，而是只是 select 了 query，这个会将运行结果显式在 sql client
界面上，而不会插入到 postgres 中。
你的 query 中有 timestamp with local time zone， 而 sql client 的 query运行结果的显式
还不支持这个类型。
这个问题的解决可以关注下这个 issue：https://issues.apache.org/jira/browse/FLINK-17948
Best,
Jark
On Tue, 8 Dec 2020 at 19:32, 李轲
谢谢
发自我的iPhone
> 在 2020年12月10日，10:49，Jark Wu 写道：
>
> 看报错信息，你并没有 insert into postgres，而是只是 select 了 query，这个会将运行结果显式在 sql client
> 界面上，而不会插入到 postgres 中。
>
> 你的 query 中有 timestamp with local time zone， 而 sql client 的 query运行结果的显式
> 还不支持这个类型。
>
> 这个问题的解决可以关注下这个 issue：https://issues.apache.org/j
