Fwd: Re: Failed to create a consumer

2015-12-30 Thread Jagadish Venkatraman
exception. It is fixed now. Rgds, Marcelo -- *From:* Jagadish Venkatraman *To:* dev@samza.apache.org; Marcelo Romaniuc *Sent:* Tuesday, December 29, 2015 5:26 AM *Subject:* Re: Failed to create a consumer Hi Marcelo, *task.inputs=product.product.txt* The for

Re: Failed to create a consumer

2015-12-28 Thread Jagadish Venkatraman
O] Got input stream metadata: > Map(SystemStream [system=product, stream=product.txt] -> > SystemStreamMetadata [streamName=product.txt, partitionMetadata={Partition > [partition=0]=SystemStreamPartitionMetadata [oldestOffset=null, > newestOffset=null, upcomingOffset=null]}]) > 2015-12-

Failed to create a consumer

2015-12-28 Thread Marcelo Romaniuc
=product, stream=product.txt] -> SystemStreamMetadata [streamName=product.txt, partitionMetadata={Partition [partition=0]=SystemStreamPartitionMetadata [oldestOffset=null, newestOffset=null, upcomingOffset=null]}]) 2015-12-28 14:17:14 SamzaContainer$ [INFO] Failed to create a consumer for prod