ERROR — [ main] org.apache.spark.streaming.StreamingContext (line: 94) : Error starting the context, marking it as stopped
java.lang.IllegalArgumentException: requirement failed: No output operations registered, so nothing to execute
at scala.Predef$.require(Predef.scala:281)
at org.apache.spark.streaming.DStreamGraph.validate(DStreamGraph.scala:169)
at org.apache.spark.streaming.StreamingContext.validate(StreamingContext.scala:518)
at org.apache.spark.streaming.StreamingContext.liftedTree1
1
(
S
t
r
e
a
m
i
n
g
C
o
n
t
e
x
t
.
s
c
a
l
a
:
578
)
a
t
o
r
g
.
a
p
a
c
h
e
.
s
p
a
r
k
.
s
t
r
e
a
m
i
n
g
.
S
t
r
e
a
m
i
n
g
C
o
n
t
e
x
t
.
s
t
a
r
t
(
S
t
r
e
a
m
i
n
g
C
o
n
t
e
x
t
.
s
c
a
l
a
:
577
)
a
t
c
o
m
.
s
s
.
a
p
p
.
S
a
l
e
D
e
t
a
i
l
A
p
p
1(StreamingContext.scala:578) at org.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:577) at com.ss.app.SaleDetailApp
1(StreamingContext.scala:578)atorg.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:577)atcom.ss.app.SaleDetailApp.main(SaleDetailApp.scala:58)
at com.ss.app.SaleDetailApp.main(SaleDetailApp.scala)
Exception in thread “main” java.lang.IllegalArgumentException: requirement failed: No output operations registered, so nothing to execute
at scala.Predef$.require(Predef.scala:281)
at org.apache.spark.streaming.DStreamGraph.validate(DStreamGraph.scala:169)
at org.apache.spark.streaming.StreamingContext.validate(StreamingContext.scala:518)
at org.apache.spark.streaming.StreamingContext.liftedTree1
1
(
S
t
r
e
a
m
i
n
g
C
o
n
t
e
x
t
.
s
c
a
l
a
:
578
)
a
t
o
r
g
.
a
p
a
c
h
e
.
s
p
a
r
k
.
s
t
r
e
a
m
i
n
g
.
S
t
r
e
a
m
i
n
g
C
o
n
t
e
x
t
.
s
t
a
r
t
(
S
t
r
e
a
m
i
n
g
C
o
n
t
e
x
t
.
s
c
a
l
a
:
577
)
a
t
c
o
m
.
s
s
.
a
p
p
.
S
a
l
e
D
e
t
a
i
l
A
p
p
1(StreamingContext.scala:578) at org.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:577) at com.ss.app.SaleDetailApp
1(StreamingContext.scala:578)atorg.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:577)atcom.ss.app.SaleDetailApp.main(SaleDetailApp.scala:58)
at com.ss.app.SaleDetailApp.main(SaleDetailApp.scala)
解决方法：
DStream只有转换原语，无输出原语
添加任意的输出原语即可，如print() foreachRDD(func)
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）