Open bboalimoe opened 8 years ago
- bolt: name: regularization_bolt module: streaming_topology.regularization_bolt groupings: - shuffle_grouping: component: kafka_user_motion - shuffle_grouping: component: kafka_user_location - bolt: name: statistic_bolt module: streaming_topology.statistic_bolt tick_freq_secs: 30.0 groupings: - fields_grouping: component: user_behavior_spout fields: - userId - type
?? 哪里不对了? @bboalimoe 下次记得at我
statistic bolt前面接的应该是 regularization bolt 而不是 spout~