e:https://issues.apache.org/jira/browse/FLINK-17948
>
> Best,
> Jark
>
>> On Tue, 8 Dec 2020 at 19:32, 李轲 wrote:
>>
>> 报错信息:
>> Exception in thread "main"
>> org.apache.flink.table.client.SqlClientException:
ient.SqlClient.start(SqlClient.java:114)
at org.apache.flink.table.client.SqlClient.main(SqlClient.java:201)
在 2020-12-08 19:24:43,"李轲" 写道:
>项目需求要向 postgres 中插入数据,用 catalog 之后,插入数据貌似需要和数据库表定义完全一致,而且没找到只插入部分字段的写法
>在时间转 TIMESTAMP(6) WITH LOCAL TIME ZONE 时报了错,这个格式是 postgres
项目需求要向 postgres 中插入数据,用 catalog 之后,插入数据貌似需要和数据库表定义完全一致,而且没找到只插入部分字段的写法
在时间转 TIMESTAMP(6) WITH LOCAL TIME ZONE 时报了错,这个格式是 postgres 中的时间戳定义
select cast(localtimestamp as TIMESTAMP(6) WITH LOCAL TIME ZONE);
有没有什么转换方法?或者只插入部分数据的方法?
可以试试ROW
发自我的iPhone
> 在 2020年12月7日,15:43,xiao cai 写道:
>
> String不行,取出来的值是null
>
>
> Original Message
> Sender: silence
> Recipient: user-zh
> Date: Monday, Dec 7, 2020 14:26
> Subject: Re: FlinkSQL如何定义JsonObject数据的字段类型
>
>
> 可以用string -- Sent from: http://apache-flink.147419.n8.nabble.com/
如果1.11想做自定义解析和映射,只能通过udf么?
发自我的iPhone
> 在 2020年12月4日,16:52,Wei Zhong 写道:
>
> Hi 你好,
>
> 这个取决于你使用的flink版本,1.11版本会自动从table schema中解析,而1.10版本如果table schema和json
> schema不是完全相同的话,需要手动写json-schema:
> https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/formats/json.ht
谢谢,了解了
发自我的iPhone
> 在 2020年12月1日,23:31,Leonard Xu 写道:
>
> Hi, 李轲
>
> 这是因为yml只支持1.10之前老的connector,写法是connector.type=‘filesystem’,
> 1.11之后的新connector都是 connetor=‘filesystem’, 除了简化了写法外,前者的工厂方法和后者的也不一样,
> 所以通过yml定义的新的connector是不能被老的工厂 SPI
> 发现的。而在yml中定义表从1.11开始就是不推荐了
在服务器上试用sql-client时,启动指令如下:
./sql-client.sh embedded -l /root/flink-sql-client/libs/ -d
/data_gas/flink/flink-1.11.2/conf/sql-client-defaults.yaml -e
/root/flink-sql-client/sql-client-demo.yml
配置如下:
# 定义表
tables:
- name: SourceTable
type: source-table
update-mode: append
conn
在服务器上试用sql-client时,启动指令如下:
./sql-client.sh embedded -d /root/flink-sql-client/sql-client-demo.yml
配置见附件,读取的文件也在附件中
遇到了如下报错:
Reading default environment from:
file:/root/flink-sql-client/sql-client-demo.yml
No session environment specified.
Exception in thread "main" org.apache.flink.ta