hi,附件挂了,没看到饿。可以考虑挂gist放链接出来。

不过看这个信息,checkpoint的失败是由于任务状态变更导致的(应该是任务重启了,所以running变scheduled了)。
建议往任务重启的方向排查一下。

Bruce <[email protected]> 于2020年8月10日周一 下午5:01写道:

> 您好,这里有个问题反馈下!
>
> 读取hive表的数据转化为流;按照jdbc两阶段提交方式写入oracle数据库,
> 没有抛任何异常但是checkpoint失败:
> job eb447d27efb8134da40c0c1dd19fffdf is not in state RUNNING but SCHEDULED
> instead. Aborting checkpoint.
> 附件
> 1.flink.log是yarn jobmanager打印的伪日志
> 2.Job.txt是job的伪代码
> 3.jdbc两阶段提交的伪代码附件
> ------------------------------
> 发自我的iPhone
>

回复