A word count of the spark program, the following
The main () {
Val a=...
Val sparkConf=new sparkConf ()...
Val SSC=new StreamingContext...
//business code
.
SSC. Start ()
SSC. AwaitTermination ()
}
What was it in the cluster process,
My understanding is:
A value assignment and initialization of SSC is executed only once, but with the relevant business code of SSC is with SSC. AwaitTermination () again and again, is that so