任务会一直重启吗?
--
Sent from: http://apache-flink.147419.n8.nabble.com/
环境: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
哈喽,请问是做了什么调整?才10秒的窗口,期待每秒都输出结果的
--
Sent from: http://apache-flink.147419.n8.nabble.com/
版本: 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如下:
版本: 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如下: