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
