流处理暂停的问题
来源:5-14 自定义Sink之功能测试

慕标8927085
2020-05-11
pk老师,写了个本地单机的流处理程序,自定义了source和sink,怎么让运行中的流处理程序停下来呢?能调用自定义sink中的cancel()方法吗或者别的办法?我现在确实有这个需求,还请PK老师指导!
写回答
1回答
-
Michael_PK
2020-05-12
反问一个问题,流本应该就是7*24不能停的呢
00
相似问题
流处理暂停的问题
来源:5-14 自定义Sink之功能测试
慕标8927085
2020-05-11
pk老师,写了个本地单机的流处理程序,自定义了source和sink,怎么让运行中的流处理程序停下来呢?能调用自定义sink中的cancel()方法吗或者别的办法?我现在确实有这个需求,还请PK老师指导!
1回答
Michael_PK
2020-05-12
反问一个问题,流本应该就是7*24不能停的呢
相似问题