Hi Renato, on the hello-samza example for each new incoming message which belongs to a channel, a new partition is created, right?
-- In WikipediaFeed job of hello-samza, each channel actually is treated as one stream of the Wikipedia System. Each stream has on partition 0. This is the code: SystemStreamPartition systemStreamPartition = new SystemStreamPartition(systemName, event.getChannel(), new Partition(0); So in your code, I think each table could be thought as one stream, with only partition 0. So it will be like task.input=ordersystem.tableName -- Then you maybe confused by what happened in Kafka. All the messages sent to wikipedia-raw topic is done in WikipediaFeedStreamTask <https://github.com/renato2099/hello-samza/blob/master/samza-wikipedia/src/main/java/samza/examples/wikipedia/task/WikipediaFeedStreamTask.java> . Exception in thread "main" org.apache.samza.SamzaException: No partitions for this task. Can't run a task without partition assignments. It's likely that the partition manager for this system doesn't know about the stream you're trying to read. at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:77) at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala) -- Is the stream registered to the system? SystemStreamPartition systemStreamPartition = new SystemStreamPartition(systemName, "order", new Partition(0); Is the "order" registered ? such as task.input=ordersystem.order ? Let me know if you have other questions. Thanks, Fang, Yan yanfang...@gmail.com +1 (206) 849-4108 On Sun, Nov 2, 2014 at 4:56 AM, Renato Marroquín Mogrovejo < renatoj.marroq...@gmail.com> wrote: > Hello Samza team, > > > I am trying to modify the hello-samza example application to replay events > which are in a table. But I am having some troubles. > So on the hello-samza example for each new incoming message which belongs > to a channel, a new partition is created, right? > Now in my case, how (where) do I create these partitions? I create them in > [1] but I am almost sure that is wrong because I keep getting the exception > saying that there are no partitions for this task. I mean ideally I would > like to create partitions based on the keys I am reading from the table. > Could anybody help me on this task please? Many thanks in advance! > > > Renato M. > > > Exception in thread "main" org.apache.samza.SamzaException: No partitions > for this task. Can't run a task without partition assignments. It's likely > that the partition manager for this system doesn't know about the stream > you're trying to read. > at org.apache.samza.container.SamzaContainer$.main(SamzaContainer.scala:77) > at org.apache.samza.container.SamzaContainer.main(SamzaContainer.scala) > > > [1] > > https://github.com/renato2099/hello-samza/blob/master/samza-wikipedia/src/main/java/samza/examples/order/system/OrderConsumer.java#L47 >
