title: spark streaming accessing azure blob
body: <p>Im trying to register my azure blob storage to my spark streaming but get this code &amp; error:- </p>
  
  <p>Code:- </p>
  
  <pre><code>SparkConf sparkConf = new SparkConf().setAppName("JavaNetworkWordCount");
          JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, Durations.seconds(1));
          ssc.textFileStream("wasb[s]://mycontainer@rtest.blob.core.windows.net/");
          ssc.start();
          ssc.awaitTermination();
  </code></pre>
  
  <p>Not sure what should be in the path of WASB link</p>
  
  <p><a href="https://docs.microsoft.com/en-us/azure/hdinsight/hdinsight-hadoop-use-blob-storage#address-files-in-azure-storage" rel="nofollow noreferrer">https://docs.microsoft.com/en-us/azure/hdinsight/hdinsight-hadoop-use-blob-storage#address-files-in-azure-storage</a></p>
  
  <p>The link says I should give a path but my container does not have any path. The images are directly stored in the container.</p>
  
  <p>Error:- </p>
  
  <pre><code>java.lang.IllegalArgumentException: requirement failed: No output operations registered, so nothing to execute
      at scala.Predef$.require(Predef.scala:224)
      at org.apache.spark.streaming.DStreamGraph.validate(DStreamGraph.scala:163)
      at org.apache.spark.streaming.StreamingContext.validate(StreamingContext.scala:513)
      at org.apache.spark.streaming.StreamingContext.liftedTree1$1(StreamingContext.scala:573)
      at org.apache.spark.streaming.StreamingContext.start(StreamingContext.scala:572)
      at org.apache.spark.streaming.api.java.JavaStreamingContext.start(JavaStreamingContext.scala:554)
      at org.bnr.process_panos.JavaNetworkWordCount.main(JavaNetworkWordCount.java:43)
      at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke(Method.java:498)
      at org.apache.spark.deploy.SparkSubmit$.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:736)
      at org.apache.spark.deploy.SparkSubmit$.doRunMain$1(SparkSubmit.scala:185)
      at org.apache.spark.deploy.SparkSubmit$.submit(SparkSubmit.scala:210)
      at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:124)
      at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
  </code></pre>