blob: 261546c02abaaf6191ed270c1907869c9e539ba8 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
#storm topology workers
#topology.workers=30
#总核数
## ZX
topology.workers=34
## HY
#topology.workers=20
## XXG
#topology.workers=5
#通联topic消费并行度
spout.parallelism=16
#FromSpoutBufferBoltDC并行度
buffer.bolt.parallelism=30
#GetSipOriBoltDC并行度
format.bolt.parallelism=300
#SipInsertBoltDC并行度
database.bolt.parallelism=30
#SipRealTimeCountBoltDC并行度
count.bolt.parallelism=30
#SipRealTimeMergeBoltDC并行度
merge.bolt.parallelism=8
#0:feild group, 1:shuffle group
group.strategy=1
#group.strategy=0
#tick时钟频率,GetSipOriBoltDC
topology.tick.tuple.comp.freq.secs=30
#tick时钟频率,SipInsertBoltDC
topology.tick.tuple.freq.secs=300
#tick时钟频率,SipRealTimeCountBoltDC
topology.tick.tuple.count.freq.secs=60
#tick时钟频率,SipRealTimeMergeBoltDC
topology.tick.tuple.merge.freq.secs=600
#topology.config.max.spout.pending=300000
topology.config.max.spout.pending=500000
topology.num.acks=0
|
