Re: DStream cannot write to text file

I'm sorry, I just forgot "/data" after "hdfs://localhost:50075". When I added it, a new exception showed up: "Call to localhost/127.0.0.1:50075 failed on local exception". How could I fix it? Thanks, Cuong. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/DSt

Re: DStream cannot write to text file

Dear Mayur Rustagi, The exception is "Incomplete HDFS URI, no host: hdfs://localhost:50075-1408602904000.output". In my situation, I receive a string from kafka, and then want to save it to text file. Could you please give me some suggestion about this? Best regards, Cuong. -- View this message

Re: Accessing to elements in JavaDStream

Thank you so much, it runs successfully. Cuong. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Accessing-to-elements-in-JavaDStream-tp12459p12557.html Sent from the Apache Spark User List mailing list archive at Nabble.com.

Re: DStream cannot write to text file

Dear Mayur Rustagi, Could you give me more detail about this? I did DStream.saveAsTextFile("hdfs://localhost:50075", "output"), but it did not work. As I see, DStream.saveAsTextFile requires two parameters, prefix and suffix, so how should I provide these types of info? Thanks in advance, Cuong.

DStream cannot write to text file

Hi, I tried to write to text file from DStream in Spark Streaming, using DStream.saveAsTextFile("test","output"), but it did not work. Any suggestions? Thanks in advance. Cuong -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/DStream-cannot-write-to-text-file

Accessing to elements in JavaDStream

Hi, I am a newbie to Spark Streaming, and I am quite confused about JavaDStream in SparkStreaming. In my situation, after catching a message "Hello world" from Kafka in JavaDStream, I want to access to JavaDStream and change this message to "Hello John", but I could not figure how to do it. Any ide