Unsubscribe

2016-06-25 Thread Shivpriya Tamboskar
Unsubscribe Sent from my iPhone - To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org

java.nio.channels.ClosedChannelException

2016-03-04 Thread Shivpriya Tamboskar
Hello community, I am running a simple consumer for kafka such as this int timeout = 8; int bufferSize = 64*1024; consumer = new SimpleConsumer(host, port,timeout, bufferSize, clientName); This runs fine for a couple for hours but I get an exception later on kafka.consumer.SimpleCo

Re: Storm-HDFS bolt file paths according to input Tuples

2016-01-04 Thread Shivpriya Tamboskar
’t pursue it beyond some high level design work. You could open a JIRA for this feature request. Thanks, Aaron From: Shivpriya Tamboskar mailto:shivpriya_tambos...@symantec.com>> Reply-To: "user@storm.apache.org<mailto:user@storm.apache.org>" mailto:user@storm.apache.org

Storm-HDFS bolt file paths according to input Tuples

2016-01-04 Thread Shivpriya Tamboskar
Hello, I am trying to write data into HDFS using the storm-hdfs bolt http://storm.apache.org/documentation/storm-hdfs.html The problem I am trying to solve is that I want the file paths to be set according to the input tuples. FileNameFormat fileNameFormat = new DefaultFileNameFormat()