| 03:04.27 | *** join/#storm jamesh (~james@canonical/launchpad/jamesh) |
| 06:40.03 | *** join/#storm jvava (~ryan@124.65.181.118) |
| 06:44.46 | jvava | when i run a localcluster example, it give me exception: backtype.storm.generated.InvalidTopologyException: null |
| 06:45.15 | jvava | i use a KafkaSpout, if use other Spout by me, it works |
| 06:54.09 | jvava | InvalidTopologyException(msg:Component: [S] subscribes from stream: [default] of component [A] with non-existent fields: #{"queryId"})> |
| 06:55.02 | jvava | i send kafka (1,1), without field name, but kafkaspout demand a fields name, how to do? |