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