clear query| facets| time Search criteria: .   Results from 21 to 30 from 68 (0.0s).
Loading phrases to help you
refine your search...
Checksum Exception : Why is it happening and how to avoid it ? - Hadoop - [mail # user]
...I am trying to upload file to s3.Locally the file is generated using :*org.apache.hadoop.io.compress.GzipCodec*The corresponding .crc file is generated too.There are 2 scenarios when the fil...
   Author: Milind Vaidya , 2016-08-10, 13:16
[expand - 1 more] - Consumer Group, relabancing and partition uniqueness - Kafka - [mail # user]
...Florin,Thanks, I got your point.The documentation as well as diagram showing the mechanism of consumergroup indicates that,the partitions are shared disjointly by consumers in agroup.You als...
   Author: Milind Vaidya , 2016-06-29, 22:25
[expand - 7 more] - Getting Kafka Offset in Storm Bolt - Storm - [mail # user]
...That was "the" thing in mind. I guess I should give it a try and then seehow it performs and see how convenient it is, can't just speculate that.On Wed, May 11, 2016 at 2:44 PM, Nathan Leung...
   Author: Milind Vaidya , 2016-05-11, 22:04
[expand - 2 more] - Data loss scenarios - Storm - [mail # user]
...Correct me if I am wrong, do you mean that the kafka log was not processeddue to slow topology (in turn bolt) and the log was deleted due toretention period exhaustion ?Thats is still config...
   Author: Milind Vaidya , 2016-01-20, 19:28
Process/Thread ids for bolts and spouts - Storm - [mail # user]
...Is there any way to know process/thread ids of kafka spout and underlyingbolts in a topology on linux command line ?As an extension of other thread about failure scenarios, I want to killman...
   Author: Milind Vaidya , 2016-01-19, 23:31
Replaying of logs and Trident - Storm - [mail # user]
...We have been using regular storm, topology-bolt set up for a while.The input to storm is from kafka cluster and zookeeper keeps the metadata.I was looking at the Trident for its exactly once...
   Author: Milind Vaidya , 2016-01-14, 19:07
NoNode exception on storm-kafka - Storm - [mail # user]
...TrySpoutConfig conf = new SpoutConfig(hosts, topicName, "/event_spout","event_spout");You had given empty string in the conf, parameter zkRoot seems missing.On Wed, Jan 13, 2016 at 4:46 PM, ...
   Author: Milind Vaidya , 2016-01-14, 18:31
[expand - 1 more] - KafkaBolt question: number of executors - Storm - [mail # user]
...Sorry, I m not sure about the max or ideal cap for number of threads forKafka bolt. But my guess is that, it will be more of a function of trafficthan mere number of topics and partition. Mo...
   Author: Milind Vaidya , 2016-01-13, 16:19
[expand - 1 more] - Avro Byte Blob Ser De - Avro - [mail # user]
...I can't thank you enough for this answer.I did almost the same thing.In my case I was using appendEncoded(ByteBuffer) instead of append(Datum).The string I was using was "This is a test stri...
   Author: Milind Vaidya , 2014-02-12, 14:33
Create Avro from bytes, not by fields - Avro - [mail # user]
...I have asked similar question but regarding deserialization of such recordswritten as Bytes.Did you try to deserilize them ?What does your schemaString look like?Please refer to thread : Avr...
   Author: Milind Vaidya , 2014-02-11, 22:29