Commit 57e5a60c by 吴延飞

Merge remote-tracking branch 'origin/master'

parents 55b715d8 f868d445
......@@ -22,7 +22,7 @@ public class GreenRadioJob {
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
FlinkUtils.createKafkaStream(args, env, "signal_cycle_data","greenRadioJob")
FlinkUtils.createKafkaStream(args, env)
.map(record -> {
// 字符串解析为实体类
Cycle cycle = JSON.parseObject(record, Cycle.class);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment