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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
| Êþº¾ 3ã
| Ò
| Ó Ô
| Ó Õ Ö × Ø Ù
| Ú Û Ü Ý
| Þ ß
| Þ à
| Ó á
| Þ â ã ä å
| C æ
| ç è
| Ú é
| Ú ê ë ì
| Þ í
| ë î
| ï ð ñ ò ñ ó
| ô
| Þ õ ö ÷
| ö ø
| C ù
| C ú û
| Ò
| ü
| Þ ý
| þ ÿ
| $ Ò
|
| Ó
| ý Ü
| , Ò
| , þ
| Þ
| ,
| Þ
| ,
|
| ,
| Þ
| ,
| ,
|
| $
| ,
| Þ
| ,
| Þ
| ,
| Þ
| ,
| ,
| , ñ
| ë
|
| G
| G!"
| #$
| G%
| &'
| M Ò(
| M)*
| +,-.
| /01
| ï2345
| M67
| ë,8
| ^ Ò9
| ^:;
| ^<=
| ö,>
| M?@ABC
| GDEF
| G
|
| ß
| H
| I
| J
| M<
| K LM
| NO PQRS ÜT
| UV
| MWXYZ
| G[\
| ]^_ logger Lorg/slf4j/Logger; <init> ()V Code LineNumberTable LocalVariableTable this .Lcom/xxl/job/admin/core/trigger/XxlJobTrigger; trigger Y(ILcom/xxl/job/admin/core/trigger/TriggerTypeEnum;ILjava/lang/String;Ljava/lang/String;)V shardingArr [Ljava/lang/String; i I jobId triggerType 0Lcom/xxl/job/admin/core/trigger/TriggerTypeEnum; failRetryCount executorShardingParam Ljava/lang/String; executorParam jobInfo )Lcom/xxl/job/admin/core/model/XxlJobInfo; finalFailRetryCount group *Lcom/xxl/job/admin/core/model/XxlJobGroup; shardingParam [I StackMapTable`a £ processTrigger (Lcom/xxl/job/admin/core/model/XxlJobGroup;Lcom/xxl/job/admin/core/model/XxlJobInfo;ILcom/xxl/job/admin/core/trigger/TriggerTypeEnum;II)V index total blockStrategy 2Lcom/xxl/job/core/enums/ExecutorBlockStrategyEnum; executorRouteStrategyEnum 8Lcom/xxl/job/admin/core/route/ExecutorRouteStrategyEnum; jobLog (Lcom/xxl/job/admin/core/model/XxlJobLog; triggerParam )Lcom/xxl/job/core/biz/model/TriggerParam; address routeAddressResult $Lcom/xxl/job/core/biz/model/ReturnT; triggerResult triggerMsgSb Ljava/lang/StringBuffer; LocalVariableTypeTable 8Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>;bcd û ' runExecutor a(Lcom/xxl/job/core/biz/model/TriggerParam;Ljava/lang/String;)Lcom/xxl/job/core/biz/model/ReturnT; executorBiz "Lcom/xxl/job/core/biz/ExecutorBiz; e Ljava/lang/Exception; runResult runResultSBR Signature u(Lcom/xxl/job/core/biz/model/TriggerParam;Ljava/lang/String;)Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>; <clinit>
| SourceFile XxlJobTrigger.java e fg hij kl 3>>>>>>>>>>>> trigger fail, jobId invalidï¼jobId={}m nop qr` st uv wx yvz {| / }~ n vc ¯
a v ¨ © b n &com/xxl/job/admin/core/model/XxlJobLog v java/util/Date +>>>>>>>>>>> xxl-job trigger start, jobId:{} r 'com/xxl/job/core/biz/model/TriggerParam ¡ ¢t £ ¤t ¥t ¦v § ¨ ©ª «¬ ® ¯ °t ± ²t ³ª ´® µ ¶ ·¸ java/lang/String ¹º» ¼½ ¾v "com/xxl/job/core/biz/model/ReturnT ¿À jobconf_trigger_address_emptyÁ Â Ã Ä Å java/lang/StringBuffer jobconf_trigger_type ÄÅ ï¼d Æ <br> jobconf_trigger_admin_adressÇ È jobconf_trigger_exe_regtype Év jobgroup_field_addressType_0 jobgroup_field_addressType_1 jobconf_trigger_exe_regaddress ÄÊ #jobinfo_field_executorRouteStrategy java/lang/StringBuilder ( ÄË ) Ì #jobinfo_field_executorBlockStrategy jobinfo_field_timeout ÄÍ $jobinfo_field_executorFailRetryCount 2<br><br><span style="color:#00c0ef;" > >>>>>>>>>>> jobconf_trigger_run <<<<<<<<<<< </span><br> Î <br><br> Ït Ðt Ñ Ò Ót Ô )>>>>>>>>>>> xxl-job trigger end, jobId:{}Õ Ö×Ø ÙÚ java/lang/Exception O>>>>>>>>>>> xxl-job trigger error, please check if the executor[{}] is running. ÛÜÝ ÌÞ t <br>addressï¼ <br>codeï¼
| <br>msgï¼ ßt ,com/xxl/job/admin/core/trigger/XxlJobTriggerà áâ java/lang/Object 'com/xxl/job/admin/core/model/XxlJobInfo (com/xxl/job/admin/core/model/XxlJobGroup 0com/xxl/job/core/enums/ExecutorBlockStrategyEnum 6com/xxl/job/admin/core/route/ExecutorRouteStrategyEnum .com/xxl/job/admin/core/trigger/TriggerTypeEnum -com/xxl/job/admin/core/conf/XxlJobAdminConfig getAdminConfig 1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig; getXxlJobInfoDao '()Lcom/xxl/job/admin/dao/XxlJobInfoDao; #com/xxl/job/admin/dao/XxlJobInfoDao loadById ,(I)Lcom/xxl/job/admin/core/model/XxlJobInfo; java/lang/Integer valueOf (I)Ljava/lang/Integer; org/slf4j/Logger warn '(Ljava/lang/String;Ljava/lang/Object;)V setExecutorParam (Ljava/lang/String;)V getExecutorFailRetryCount ()I getXxlJobGroupDao (()Lcom/xxl/job/admin/dao/XxlJobGroupDao; getJobGroup $com/xxl/job/admin/dao/XxlJobGroupDao load -(I)Lcom/xxl/job/admin/core/model/XxlJobGroup; split '(Ljava/lang/String;)[Ljava/lang/String; $org/apache/commons/lang3/StringUtils isNumeric (Ljava/lang/CharSequence;)Z '(Ljava/lang/String;)Ljava/lang/Integer; intValue SHARDING_BROADCAST getExecutorRouteStrategy ()Ljava/lang/String; match (Ljava/lang/String;Lcom/xxl/job/admin/core/route/ExecutorRouteStrategyEnum;)Lcom/xxl/job/admin/core/route/ExecutorRouteStrategyEnum; getRegistryList ()Ljava/util/List; java/util/List isEmpty ()Z size getExecutorBlockStrategy SERIAL_EXECUTION x(Ljava/lang/String;Lcom/xxl/job/core/enums/ExecutorBlockStrategyEnum;)Lcom/xxl/job/core/enums/ExecutorBlockStrategyEnum; (I)Ljava/lang/String; concat &(Ljava/lang/String;)Ljava/lang/String; setJobGroup (I)V getId setJobId setTriggerTime (Ljava/util/Date;)V getXxlJobLogDao &()Lcom/xxl/job/admin/dao/XxlJobLogDao; "com/xxl/job/admin/dao/XxlJobLogDao save +(Lcom/xxl/job/admin/core/model/XxlJobLog;)I debug getExecutorHandler setExecutorHandler getExecutorParam setExecutorParams setExecutorBlockStrategy getExecutorTimeout setExecutorTimeout setLogId getTriggerTime ()Ljava/util/Date; getTime ()J setLogDateTim (J)V getGlueType setGlueType getGlueSource setGlueSource getGlueUpdatetime setGlueUpdatetime setBroadcastIndex setBroadcastTotal get (I)Ljava/lang/Object; getRouter /()Lcom/xxl/job/admin/core/route/ExecutorRouter; +com/xxl/job/admin/core/route/ExecutorRouter route _(Lcom/xxl/job/core/biz/model/TriggerParam;Ljava/util/List;)Lcom/xxl/job/core/biz/model/ReturnT; getCode
| getContent ()Ljava/lang/Object; $com/xxl/job/admin/core/util/I18nUtil getString (ILjava/lang/String;)V append ,(Ljava/lang/String;)Ljava/lang/StringBuffer; getTitle com/xxl/rpc/util/IpUtil getIp getAddressType ,(Ljava/lang/Object;)Ljava/lang/StringBuffer; -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString (I)Ljava/lang/StringBuffer; getMsg setExecutorAddress setExecutorShardingParam setExecutorFailRetryCount setTriggerCode setTriggerMsg updateTriggerInfo 6com/xxl/job/admin/core/schedule/XxlJobDynamicScheduler getExecutorBiz 6(Ljava/lang/String;)Lcom/xxl/job/core/biz/ExecutorBiz; com/xxl/job/core/biz/ExecutorBiz run O(Lcom/xxl/job/core/biz/model/TriggerParam;)Lcom/xxl/job/core/biz/model/ReturnT; error 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V com/xxl/rpc/util/ThrowableUtil )(Ljava/lang/Throwable;)Ljava/lang/String; setMsg org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; !
| / *· ± )
| ¸ ¶ ¹ :Ç ² ¸ ¹ ±Æ
| ¶ § ¶
| 6¸ ¶ ¶ ¹ ::-Æ G-¶ : ¾ 8 2¸ . 2¸ $¼
| : 2¸ ¶ O 2¸ ¶ O² ¶ ¸ ¦ N¶ Æ F¶ ¹ 9Ç 46 ¶ ¹ ¢ + ¶ ¹ ¸ §ÿا 'Ç ¼
| YOYO:+..¸ ± b , - . ! / " 1 ' 2 . 4 = 5 O 8 R 9 V : ^ ; y < ~ = > A « B Ã D Õ E ë D ô H ù I K N p ^ < Æ + = Ü O Ê ¡ R Ç ¢ £ ¤
| ü " ¥ Dþ ^ ¦ §ü +ú *
| ¨ © [ x+¶ ² ¸ :+¶ ¸ :² ¦ ¸ ¶ ¸ ¶ § :» Y· : +¶ ¶ ! +¶ "¶ # » $Y· %¶ &¸ ¶ ' ¹ ( W² ) ¶ *¸ ¹ + » ,Y· -:
|
| +¶ "¶ .
| +¶ /¶ 0
| +¶ 1¶ 2
| +¶ ¶ 3
| +¶ 4¶ 5
| ¶ *¶ 6
| ¶ 7¶ 8¶ 9
| +¶ :¶ ;
| +¶ <¶ =
| +¶ >¶ 8¶ ?
| ¶ @
| ¶ A: : *¶ Æ r*¶ ¹ f² ¦ 6*¶ ¹ ¢ *¶ ¹ B À C: § N*¶ ¹ B À C: § <¶ D
| *¶ ¶ E: ¶ F È ! ¶ HÀ C: § » GYôI¸ J· K: : Æ
| ¸ L: § » GYô· K: » MY· N:O¸ J¶ PQ¶ P-¶ R¶ PWS¶ PT¸ J¶ PQ¶ P¸ U¶ PWS¶ PV¸ J¶ PQ¶ P*¶ W X¸ J§ Y¸ J¶ PWS¶ PZ¸ J¶ PQ¶ P*¶ ¶ [WS¶ P\¸ J¶ PQ¶ P¶ ]¶ PWÆ "» ^Y· _`¶ a¶ ab¶ a¶ c¶ PWS¶ Pd¸ J¶ PQ¶ P¶ e¶ PWS¶ Pf¸ J¶ PQ¶ P+¶ 4¶ gWS¶ Ph¸ J¶ PQ¶ P ¶ gW» ^Y· _i¶ aj¸ J¶ ak¶ a¶ c¶ P Æ % ¶ lÆ » ^Y· _ ¶ l¶ am¶ a¶ c§ n¶ P ¶ lÆ ¶ l§ n¶ PW ¶ o +¶ /¶ p +¶ 1¶ q ¶ r ¶ s ¶ F¶ t ¶ u¶ v¸ ¶ ' ¹ w W² x ¶ *¸ ¹ + ± ö = [ \ ] 6 ` ? a H b Q c ] d k e } h i j k ¡ l ª m ³ n ½ o Ê p Ó q Ü r è s ï t ö w ù x ü y z {% |8 ~J Z e r ¤ Ä ß ô ' D I h
¡ º ¡â ¢ ¥$ ¦- §6 ¨= ©C «M ¬W e ¯w ° x ¡ x x x x ª x « l ¬ b ® ¯ 6B ¢ ?9 ° ± ò ² ³
| ù ´ ü| µ ¶ ò · ¶ Ë ¸ ¹ º ü| µ » ò · » ¤ ý 3 ¼ ½@ ¾ÿ ¦ ¥ ¿ ¼ ½ ¾ À Á ¾ Â 'ü Â ÿ ] ¦ ¥ ¿ ¼ ½ ¾ À Á ¾ Â Â Ã Ãÿ ¦ ¥ ¿ ¼ ½ ¾ À Á ¾ Â Â Ã Ã ¾û `÷ Ãÿ ¦ ¥ ¿ ¼ ½ ¾ À Á ¾ Â Â Ã Ã ¾R Ãÿ ¦ ¥ ¿ ¼ ½ ¾ À Á ¾ Â Â Ã Ã ¾ Ä Å @ ~M+¸ yN-*¹ z M§ N² |+-¹ } » GYô-¸ ~· KM» MY» ^Y· _j¸ J¶ aQ¶ a¶ c· N-¶ P+¶ PW-¶ P,¶ F¶ gW-¶ P,¶ l¶ PW,-¶ u¶ ,° { 6 ¹ » ¼ À ½ ¾ ¿ . Â M Ã X Ä f Å t Ç | È > Æ Ç È É ~ ² ³ ~ ´ | Ê ¶ M 1 Ë ¹ º | Ê » ¤ ÿ Á ¾ Â Ì Í Î Ï ! ¸
³ ± Ð Ñ
|
|
