多多色-多人伦交性欧美在线观看-多人伦精品一区二区三区视频-多色视频-免费黄色视屏网站-免费黄色在线

國內(nèi)最全I(xiàn)T社區(qū)平臺 聯(lián)系我們 | 收藏本站
阿里云優(yōu)惠2
您當(dāng)前位置：首頁 > 互聯(lián)網(wǎng) > （三　）kafka-jstorm集群實(shí)時(shí)日志分析 之 ---------jstorm集成spring　續(xù)（代碼）

（三　）kafka-jstorm集群實(shí)時(shí)日志分析 之 ---------jstorm集成spring　續(xù)（代碼）

來源：程序員人生   發(fā)布時(shí)間：2014-11-08 08:04:49 閱讀次數(shù)：5293次

　　本地模式啟動的．

package com.doctor.kafkajstrom; import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; import org.apache.commons.lang.RandomStringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.ApplicationContext; import com.doctor.kafkajstrom.log.manager.LogManager; import com.doctor.kafkajstrom.util.SpringUtil; import backtype.storm.Config; import backtype.storm.LocalCluster; import backtype.storm.spout.SpoutOutputCollector; import backtype.storm.task.OutputCollector; import backtype.storm.task.TopologyContext; import backtype.storm.topology.OutputFieldsDeclarer; import backtype.storm.topology.TopologyBuilder; import backtype.storm.topology.base.BaseRichBolt; import backtype.storm.topology.base.BaseRichSpout; import backtype.storm.tuple.Fields; import backtype.storm.tuple.Tuple; import backtype.storm.tuple.Values; public class LocalJstormMain { public static void main(String[] args) { // Topology definition TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("word-reader", new WordReaderSpoutCh03()); builder.setSpout("signals-spout", new SignalsSpoutCh03(),6); builder.setBolt("word-normalizer", new WordTransformBoltCh03(),6) .shuffleGrouping("word-reader"); builder.setBolt("word-counter", new WordCounterBoltCh03(), 2) .fieldsGrouping("word-normalizer", new Fields("word")) .allGrouping("signals-spout", "signals"); // Configuration Config conf = new Config(); conf.setNumWorkers(3); conf.setDebug(true); // Topology run conf.put(Config.TOPOLOGY_MAX_SPOUT_PENDING, 1); LocalCluster cluster = new LocalCluster(); cluster.submitTopology("Count-Word-Toplogy-With-Refresh-Cache", conf, builder.createTopology()); // try { // TimeUnit.MINUTES.sleep(2); // } catch (InterruptedException e) { // e.printStackTrace(); // } // cluster.killTopology("Count-Word-Toplogy-With-Refresh-Cache"); // cluster.shutdown(); } public static class WordReaderSpoutCh03 extends BaseRichSpout { private static final Logger log = LoggerFactory.getLogger(WordReaderSpoutCh03.class); private static final long serialVersionUID = 1L; private TopologyContext context; private SpoutOutputCollector collector; private static final String WORDS = "sjdkfjksdjfdkjaaa中觸及看對方的罰款多級"; @Override public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) { this.context = context; this.collector = collector; } @Override public void ack(Object msgId) { log.info("{Ok:{}}", msgId); } @Override public void fail(Object msgId) { log.info("{Ok:{}}", msgId); } @Override public void nextTuple() { this.collector.emit(new Values(RandomStringUtils.random(6, WORDS))); } @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { declarer.declare(new Fields("line")); } } public static class SignalsSpoutCh03 extends BaseRichSpout { private static final long serialVersionUID = 1L; private SpoutOutputCollector spoutOutputCollector; @Override public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) { this.spoutOutputCollector = collector; } @Override public void nextTuple() { this.spoutOutputCollector.emit("signals", new Values("refreshCache")); try { TimeUnit.MILLISECONDS.sleep(2); } catch (Throwable e) { } } @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { declarer.declareStream("signals", new Fields("action")); } } public static class WordTransformBoltCh03 extends BaseRichBolt { private static final long serialVersionUID = 1L; private OutputCollector collector; private int numCounterTasks = 0; @Override public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) { this.collector = collector; this.numCounterTasks = context.getComponentTasks("word-counter").size(); } @Override public void execute(Tuple input) { String[] lines = input.getString(0).split(" "); for (String line : lines) { String lowerCase = line.trim().toLowerCase(); if (!lowerCase.isEmpty()) { this.collector.emit(new Values(line)); } } this.collector.ack(input); } @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { declarer.declare(new Fields("word")); } } public static class WordCounterBoltCh03 extends BaseRichBolt { private static final Logger log = LoggerFactory.getLogger(WordCounterBoltCh03.class); private static final long serialVersionUID = 1L; private Map<String, Integer> countMap; private OutputCollector collector; private String name; private int id; private static final ApplicationContext applicationContext; private static final LogManager logManager; static{ applicationContext = SpringUtil.of("learningJstormConfig/spring-kafkabolt-context.xml"); logManager = applicationContext.getBean(LogManager.class); log.info("--------------ApplicationContext initialized from learningJstormConfig/spring-kafkabolt-context.xml "); } @Override public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) { this.countMap = new HashMap<>(); this.collector = collector; this.name = context.getThisComponentId(); this.id = context.getThisTaskId(); log.info("-----------------WordCounterBoltCh03 prepare"); } @Override public void execute(Tuple input) { String word = null; try { word = input.getStringByField("word"); } catch (Throwable e) { } if (null != word) { if (!countMap.containsKey(word)) { countMap.put(word, 1); } else { Integer count = countMap.get(word); count++; countMap.put(word, count); logManager.write(word + ":" + countMap.get(word)); } } else { if ("signals.".equals(input.getSourceStreamId()) && "refreshCache".equals(input.getStringByField("action"))) { cleanup(); countMap.clear(); } } this.collector.ack(input); } @Override public void declareOutputFields(OutputFieldsDeclarer declarer) { } @Override public void cleanup() { log.info("{cleanup................}"); countMap.forEach((k, v) -> { log.info("{clean up.................}"); log.info("k : {} , v : {}", k, v); }); } } }
　Spring加載代碼：

public final class SpringUtil { private SpringUtil() { throw new IllegalAccessError("constructor should not http://www.vxbq.cn/access/"); } public static ApplicationContext of(String classPathConfigLocation){ return new ClassPathXmlApplicationContext(classPathConfigLocation); } }


ｓｐｒｉｎｇ　配置文件：

<?xml version="1.0" encoding="UTF⑻"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd"> <import resource="classpath:/learningJstormConfig/dubbo-provider.xml"/> <context:component-scan base-package="com.doctor.kafkajstrom.log.manager.imp" /> <context:component-scan base-package="com.doctor.kafkajstrom.log.service.imp" /> <context:component-scan base-package="com.doctor.kafkajstrom.component" /> </beans>

部份運(yùn)行結(jié)果：

59519 [word-counter:2-BoltExecutors] ERROR kafka.producer.async.DefaultEventHandler  - Failed to send requests for topics kafka-test with correlation ids in [145,152]
10⑶0 22:15:11.581 word-counter:2-BoltExecutors INFO  c.d.k.l.m.i.LogManagerImp -  LogManagerImp write method :jdjkkj:2
10⑶0 22:15:12.021 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[的kakd的]
10⑶0 22:15:12.021 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[a罰j的j的]
10⑶0 22:15:12.021 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[涉方的級df]
10⑶0 22:15:12.021 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[kkas罰d]
10⑶0 22:15:12.021 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[對ja看sf]
10⑶0 22:15:12.022 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[a對的及kd]
10⑶0 22:15:12.022 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[及ks中方中]
10⑶0 22:15:12.022 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[j多方多級級]
10⑶0 22:15:12.022 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[涉j對fas]
10⑶0 22:15:12.022 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[kasa款級]
10⑶0 22:15:12.022 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[j多多aa多]
10⑶0 22:15:12.022 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[fjda觸及]
10⑶0 22:15:12.022 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[kkja觸及]
10⑶0 22:15:12.022 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [2]:[及s及ddk]
10⑶0 22:15:12.022 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[s及dks對]
10⑶0 22:15:12.022 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[jfd中a中]
10⑶0 22:15:12.023 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[jadj及涉]
10⑶0 22:15:12.023 signals-spout:15-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:15 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.023 signals-spout:14-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:14 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.023 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[多a多中a涉]
10⑶0 22:15:12.023 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[多方多及ad]
10⑶0 22:15:12.023 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[d中djfd]
10⑶0 22:15:12.024 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [1]:[及fd款對j]
10⑶0 22:15:12.024 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[及ksjjs]
10⑶0 22:15:12.024 signals-spout:11-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:11 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.024 signals-spout:12-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:12 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.024 signals-spout:16-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:16 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.024 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[j多f多kj]
10⑶0 22:15:12.025 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[中看f中罰a]
10⑶0 22:15:12.025 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[s罰j款看罰]
10⑶0 22:15:12.025 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[f罰s及多罰]
10⑶0 22:15:12.025 signals-spout:13-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:13 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.025 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[款kk級f涉]
10⑶0 22:15:12.026 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[k多k對方k]
10⑶0 22:15:12.026 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[fs的及aj]
10⑶0 22:15:12.026 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[j看款k級款]
10⑶0 22:15:12.027 signals-spout:14-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:14 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.027 signals-spout:15-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:15 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.027 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[df的aaj]
10⑶0 22:15:12.027 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [2]:[及對級djd]
10⑶0 22:15:12.027 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[a級j對的看]
10⑶0 22:15:12.028 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [2]:[k罰a觸及k]
10⑶0 22:15:12.028 signals-spout:16-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:16 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.028 signals-spout:12-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:12 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.028 signals-spout:11-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:11 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.028 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[款涉罰dad]
10⑶0 22:15:12.029 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[看中d方aj]
10⑶0 22:15:12.029 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [1]:[jaj中對款]
10⑶0 22:15:12.029 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [2]:[jk中d級看]
10⑶0 22:15:12.029 signals-spout:13-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:13 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.030 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [1]:[中j對kj及]
10⑶0 22:15:12.030 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[d中罰的k中]
10⑶0 22:15:12.030 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[kj多方d對]
10⑶0 22:15:12.031 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[sa看j的d]
10⑶0 22:15:12.031 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [1]:[的k多f款多]
10⑶0 22:15:12.031 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[kj中js的]
10⑶0 22:15:12.031 signals-spout:14-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:14 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.031 signals-spout:15-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:15 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.031 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[d中jkss]
10⑶0 22:15:12.032 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[涉看k看的a]
10⑶0 22:15:12.032 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[a級對級及看]
10⑶0 22:15:12.032 signals-spout:16-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:16 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.032 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[jdjak看]
10⑶0 22:15:12.032 signals-spout:12-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:12 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.032 signals-spout:11-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:11 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.032 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[級fa方kj]
10⑶0 22:15:12.032 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[對kaj中方]
10⑶0 22:15:12.033 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[ajdj中d]
10⑶0 22:15:12.033 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [2]:[jdd及對對]
10⑶0 22:15:12.033 signals-spout:13-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:13 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.033 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[f的ff罰f]
10⑶0 22:15:12.034 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[saaada]
10⑶0 22:15:12.034 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[ska方對s]
10⑶0 22:15:12.034 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[罰aj中d看]
10⑶0 22:15:12.034 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [1]:[dsj多看對]
10⑶0 22:15:12.035 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [2]:[j級s對aj]
10⑶0 22:15:12.035 signals-spout:15-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:15 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.035 signals-spout:14-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:14 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.035 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[sj中涉方a]
10⑶0 22:15:12.035 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[akkjdf]
10⑶0 22:15:12.035 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[kad及s方]
10⑶0 22:15:12.036 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[a看中a看d]
10⑶0 22:15:12.036 signals-spout:16-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:16 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.036 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [1]:[k級看k的涉]
10⑶0 22:15:12.036 signals-spout:12-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:12 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.036 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [2]:[kdaaa及]
10⑶0 22:15:12.036 signals-spout:11-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:11 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.037 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[級多jjjj]
10⑶0 22:15:12.037 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[及jsajd]
10⑶0 22:15:12.037 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [1]:[及a款afs]
10⑶0 22:15:12.037 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[款對j罰k看]
10⑶0 22:15:12.037 signals-spout:13-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:13 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.037 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[k級asa方]
10⑶0 22:15:12.037 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [2]:[f款sk涉方]
10⑶0 22:15:12.038 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[ks及多款a]
10⑶0 22:15:12.038 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[fjkfa看]
10⑶0 22:15:12.038 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [1]:[fjjaa對]
10⑶0 22:15:12.038 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [1]:[jfkf對k]
10⑶0 22:15:12.038 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[款涉多s方級]
10⑶0 22:15:12.038 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[級及kss級]
10⑶0 22:15:12.038 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[涉k中kjj]
10⑶0 22:15:12.038 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[jjjdjs]
10⑶0 22:15:12.038 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[ajjadf]
10⑶0 22:15:12.038 signals-spout:15-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:15 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.038 signals-spout:14-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:14 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.038 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [2]:[f對dd多a]
10⑶0 22:15:12.039 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [2]:[方級j涉中款]
10⑶0 22:15:12.039 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [2]:[看看及級aj]
10⑶0 22:15:12.039 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[fd方d多涉]
10⑶0 22:15:12.039 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[的j對as級]
10⑶0 22:15:12.039 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [2]:[ka罰對看j]
10⑶0 22:15:12.039 signals-spout:16-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:16 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.039 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [2]:[djs款fa]
10⑶0 22:15:12.039 signals-spout:12-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:12 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.039 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [1]:[款的及jf方]
10⑶0 22:15:12.040 signals-spout:11-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:11 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.040 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[ddskjs]
10⑶0 22:15:12.040 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [1]:[款asjjk]
10⑶0 22:15:12.040 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [1]:[s級jas級]
10⑶0 22:15:12.040 word-normalizer:7-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:7 default to [1]:[da及s及方]
10⑶0 22:15:12.040 word-normalizer:8-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:8 default to [2]:[款saajs]
10⑶0 22:15:12.040 word-normalizer:3-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:3 default to [1]:[k中djsj]
10⑶0 22:15:12.040 signals-spout:13-SingleThreadSpoutExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from signals-spout:13 signals to [1, 2]:[refreshCache]
10⑶0 22:15:12.041 word-normalizer:4-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:4 default to [1]:[akf中罰罰]
10⑶0 22:15:12.041 word-normalizer:6-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:6 default to [2]:[j看的看方k]
10⑶0 22:15:12.041 word-normalizer:5-BoltExecutors INFO  c.a.j.t.c.TaskSendTargets -  Emit from word-normalizer:5 default to [2]:[djjaa及]

生活不易，碼農(nóng)辛苦
如果您覺得本網(wǎng)站對您的學(xué)習(xí)有所幫助,可以手機(jī)掃描二維碼進(jìn)行捐贈
程序員人生
------分隔線----------------------------
分享到:
------分隔線----------------------------
為碼而活
積分：4237
15粉絲
7關(guān)注
欄目熱點(diǎn)
關(guān)閉
程序員人生
主站蜘蛛池模板： 国产精品日韩欧美 | 成人精品美女隐私漫画 | 午夜三级理论在线观看视频 | 中文字幕国产欧美 | 在线免费观看国产视频 | 国产精品精品 | 亚洲视频在线观看网址 | 在线观看精品福利片香蕉 | 欧美日韩不卡码一区二区三区 | www.亚洲色图| 精品久久久久久国产 | 欧美一级www | 免费欧洲毛片a级视频无风险 | 久久91精品国产一区二区 | 日韩色视频一区二区三区亚洲 | 国产九色在线 | 亚洲国产视频在线观看 | 亚洲视频自拍 | 国产成人精品免费视频网页大全 | 欧美国产成人一区二区三区 | 久久999精品| 国产免费高清在线精品一区 | 国产成人综合亚洲欧美在 | 中文字幕人成不卡一区 | 欧美国产一区二区二区 | 欧美久久超级碰碰碰二区三区 | 免费高清国产 | 亚洲综合精品一二三区在线 | 亚洲视频观看 | 精品中文字幕不卡在线视频 | 中文字幕在线观看免费 | 亚洲免费视频在线 | 日韩欧美亚洲综合一区二区 | 欧美色综合网站 | 免费v片在线看 | 日本大片免费播放网站 | 一区二区三区视频在线 | 欧美国产亚洲精品高清不卡 | 中文字幕曰韩一区二区不卡 | 一二三四在线观看视频 | 亚洲国产高清视频在线观看 |