flink实时双流驱动join问题

2022-09-16 文章 casel.chen
请教一个flink实现实时双流驱动join问题: order cdc流字段:order_id, order_status, order_time, user_id (order_id是主键) user cdc流字段:user_id, user_name, user_phone, user_address(user_id是主键) 关联结果流字段:order_id, order_status, order_time, user_name, user_phone, user_address(order_id是主键) 期望当order流数据更新或user流数据更新时,关联结果流数据都会得到更新

Re: 任务启动异常导致Flink服务挂掉,无法启动Flink服务

2022-09-16 文章 yidan zhao
嗯。去zookeeper中删除jobgraph和running job xx吧啦的几个节点。 Summer 于2022年9月16日周五 16:51写道: > 开了,但是全被干挂了 > 回复的原邮件 > 发件人 yidan zhao > 发送日期 2022年9月16日 16:05 > 收件人 Summer > 抄送人 user-zh@flink.apache.org > > 主题 Re: 任务启动异常导致Flink服务挂掉,无法启动Flink服务 > HA模式开启了对嘛。 > > Summer 于2022年9月16日周五 15:48写道: > >> 原因是找到

回复: 任务启动异常导致Flink服务挂掉,无法启动Flink服务

2022-09-16 文章 Summer
开了,但是全被干挂了 回复的原邮件 发件人 yidan zhao发送日期 2022年9月16日 16:05收件人 Summer抄送人 user-zh@flink.apache.org主题 Re: 任务启动异常导致Flink服务挂掉,无法启动Flink服务 HA模式开启了对嘛。 Summer 于2022年9月16日周五 15:48写道: 原因是找到了,${FLINK_HOME}/lib缺少了一个任务依赖Jar包, 那么如果我在不添加这个jar的情况下,由于Flink无法启动,怎么才能取消掉这个任务?? 回复的原邮件 -

Re: 任务启动异常导致Flink服务挂掉,无法启动Flink服务

2022-09-16 文章 yidan zhao
HA模式开启了对嘛。 Summer 于2022年9月16日周五 15:48写道: > 原因是找到了,${FLINK_HOME}/lib缺少了一个任务依赖Jar包, > 那么如果我在不添加这个jar的情况下,由于Flink无法启动,怎么才能取消掉这个任务?? > > > > 回复的原邮件 > 发件人 yidan zhao > 发送日期 2022年9月16日 14:51 > 收件人 Summer > 抄送人 user-zh@flink.apache.org > > 主题 Re: 任务启动异常导致Flink服务挂掉,无法启动Flink服务 > 开启了HA是吧。 >

回复: 任务启动异常导致Flink服务挂掉,无法启动Flink服务

2022-09-16 文章 Summer
原因是找到了,${FLINK_HOME}/lib缺少了一个任务依赖Jar包, 那么如果我在不添加这个jar的情况下,由于Flink无法启动,怎么才能取消掉这个任务?? 回复的原邮件 发件人 yidan zhao发送日期 2022年9月16日 14:51收件人 Summer抄送人 user-zh@flink.apache.org主题 Re: 任务启动异常导致Flink服务挂掉,无法启动Flink服务 开启了HA是吧。 Summer 于2022年9月16日周五 14:32写道: standlone部署 回复的原