Re: 回复: Re:回复: flink-1.11.2 执行checkpoint失败

2021-03-10 文章 smallwong
任务会一直重启吗? -- Sent from: http://apache-flink.147419.n8.nabble.com/

Flink1.11.2写hive提示UnknownHostException

2020-12-06 文章 smallwong
环境:Flink1.11.2, CDH5.13.3(Hive1.1.0) 已使用的方法: flink-conf.yaml中设置env.yarn.conf.dir,另外也检测集群配置,hdfs-site.xml没问题,但都无效 异常: Caused by: java.net.UnknownHostException: nameservice at org.apache.hadoop.security.SecurityUtil.buildTokenService(SecurityUtil.java:406) ~[hadoop-common.jar:?] at

Re: flinksql如何控制结果输出的频率

2020-10-14 文章 smallwong
哈喽,请问是做了什么调整?才10秒的窗口,期待每秒都输出结果的 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Field types of query result and registered TableSink 'table' do not match.

2020-09-27 文章 smallwong
版本: 1.10.1 引擎:flink 先创建的table表schema如下: -- root |-- address: STRING |-- tum: TIMESTAMP(3) |-- tum_count: BIGINT table2表schema如下: root |-- name: STRING |-- age: STRING |-- field_time: TIMESTAMP(3) |-- address: STRING |-- proctimeField: TIMESTAMP(3) 其中proctimeField是PROCTIME 然后执行sql如下:

Field types of query result and registered TableSink 'table' do not match.

2020-09-27 文章 smallwong
版本: 1.10.1 引擎:flink 先创建的table表schema如下: -- root |-- address: STRING |-- tum: TIMESTAMP(3) |-- tum_count: BIGINT table2表schema如下: root |-- name: STRING |-- age: STRING |-- field_time: TIMESTAMP(3) |-- address: STRING |-- proctimeField: TIMESTAMP(3) 其中proctimeField是PROCTIME 然后执行sql如下: