流处理暂停的问题

来源:5-14 自定义Sink之功能测试

慕标8927085

2020-05-11

pk老师,写了个本地单机的流处理程序,自定义了source和sink,怎么让运行中的流处理程序停下来呢?能调用自定义sink中的cancel()方法吗或者别的办法?我现在确实有这个需求,还请PK老师指导!

写回答

1回答

Michael_PK

2020-05-12

反问一个问题,流本应该就是7*24不能停的呢

0
0

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程