大家好,请教个问题,在sparkStreaming,我实现了StreamingListener 的接口,用于监控数据堆积的情况,在 onBatchCompleted 判断后调用 stop 会抛出 Cannot stop StreamingContext within listener thread of SparkListenerBus 的异常,异常是在下面源码截图中抛出来的,说我当前实时监控的线程还存在不允许stop ,有些不解,哪位大佬给指点下,是我操作不当?还是再做stop 时需要满足什么条件?-问答-阿里云开发者社区-阿里云

开发者社区> 社区小助手> 正文

大家好,请教个问题,在sparkStreaming,我实现了StreamingListener 的接口,用于监控数据堆积的情况,在 onBatchCompleted 判断后调用 stop 会抛出 Cannot stop StreamingContext within listener thread of SparkListenerBus 的异常,异常是在下面源码截图中抛出来的,说我当前实时监控的线程还存在不允许stop ,有些不解,哪位大佬给指点下,是我操作不当?还是再做stop 时需要满足什么条件?

2019-05-23 09:43:18 3592 1

下图是我写的代码,以及源码抛异常的地方。
2
3

取消 提交回答
全部回答(1)
  • 社区小助手
    2019-07-17 23:35:53

    onBatchComplete里面不可以调用ssc.stop,不然岂不是一个batch做完的时候,整个作业就被关掉了。ssc.stop在所有的listener里面都不应该调用

    0 0
相关问答

11

回答

在阿里云上安装和运行Node.js全功略

ycwong 2013-09-18 15:17:30 64036浏览量 回答数 11

132

回答

【一直被追赶,从未被超越】万网主机技术全面升级,抢先看,赢大奖 !

dengcf 2014-11-10 15:03:27 31875浏览量 回答数 132

8

回答

OceanBase 使用动画(持续更新)

mq4096 2019-02-20 17:16:36 333892浏览量 回答数 8

20

回答

【阿里云产品公测】简单日志服务SLS使用评测含教程

mr_wid 2014-10-09 07:18:30 41036浏览量 回答数 20

19

回答

终于发现服务器流量被大量占用的原因,原来就是阿里云的问题!!!!!

neowo 2015-08-19 08:33:40 68868浏览量 回答数 19

35

回答

如何优化网站的访问速度

cnsjw 2014-08-27 11:08:51 32022浏览量 回答数 35

58

回答

阿里云RDS产品经理访谈,等你来提问

xiaofanqie 2014-11-05 16:28:20 37373浏览量 回答数 58

12

回答

Node.js应用性能监控与问题诊断【精品问答集锦】

管理贝贝 2016-08-29 17:10:59 36989浏览量 回答数 12

16

回答

【阿里云三周年】Teamcola与阿里云的分分合合

maklu 2012-09-10 21:40:10 34245浏览量 回答数 16

19

回答

萌妹来袭!《经典云案例》第二期崩坏学园2-APP STORE付费榜NO.1

pittman03 2014-04-03 11:07:02 63483浏览量 回答数 19
+关注
社区小助手
社区小助手是spark中国社区的管理员,我会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关spark的问题及回答。
12
文章
824
问答
推荐问答
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载