Re: flink SQL如何将秒转换为timestamp

hi t as TO_TIMESTAMP(FROM_UNIXTIME(ts/1000,'-MM-dd HH:mm:ss')) 这样设置就可以了. Best JasonLee 发件人： zilong xiao 发送时间： 2020-06-30 16:29 收件人： user-zh 主题： flink SQL如何将秒转换为timestamp 有一个字段itime，类型为int，意为当前时间的秒值，如何将该字段转换成timestamp？以下是我的想法，不知是否正确，求遇到过类似问题的大佬指导 TO_TIMESTAMP(DATE_FORMAT(CAST(itime *

Re: 关于local cluster的问题

hi 你这个问题没有描述清楚啊 是提交一个任务jm就会自动启动一个? Best JasonLee 发件人： naisili Yuan 发送时间： 2020-06-30 18:29 收件人： user-zh 主题： 关于local cluster的问题 Hi all 我这边有写一个java服务去自动拉起本地flink cluster（单机模式）用来调试使用。我是直接调用的bin/start-cluster.sh脚本。 现在问题是每次重新发布服务之后，发现这个启动的会话jobmanager会自动增加一个，导致slots总数越来越高。研究半天始终没找到原因，希望获得帮助！

回复: flink1.9 on yarn

问题1 ./bin/flink run -m yarn-cluster每次提交是都会产生一个新的APP-ID如:application_1567067657620_0254 当yarn application -kill application_1567067657620_0254后， 在提交./bin/flink run -m yarn-cluster如何不让这个appid递增？ 问题2 ./bin/flink run -m yarn-cluster提交任务后。cancel掉job，如何在提交到这个appid上？