Êþº¾ 4û
|
ß
|
à á
|
à â ã ä å æ
|
ç è é ê
|
ë ì
|
ë í
|
à î
|
ë ï ð ñ
|
I ò
|
I ó
|
ô õ
|
ô ö ÷
|
I ø
|
ù
|
ç ú
|
ç û ü ý
|
ë þ
|
ü ÿ
|
ô
|
|
ë
|
|
I
|
|
I
|
$ ß
|
$
|
ë
|
$
|
) ß
|
$
|
à
|
$
|
é
|
2 ß
|
2
|
ë
|
2
|
ë
|
2
|
2
|
ë
|
2!
|
2"
|
$#
|
)$
|
2%
|
ë&
|
2'
|
ë(
|
2)
|
ë*
|
2+
|
2,
|
2- ./
|
ü0
|
12
|
M34
|
M56
|
78
|
M9
|
:;
|
S ß<
|
S=>
|
?@AB
|
CDE
|
ôFGHI
|
SJK
|
ü@L
|
d ßM
|
dNO
|
dPQ
|
@R
|
SSTUVW
|
MXYZ
|
$[
|
$
|
$ ì
|
$\
|
$]
|
$^
|
SP
|
$_ `a
|
bc defg éh
|
ij
|
Sklmn
|
Mop
|
qrs logger Lorg/slf4j/Logger; <init> ()V Code LineNumberTable LocalVariableTable this .Lcom/xxl/job/admin/core/trigger/XxlJobTrigger; trigger k(ILcom/xxl/job/admin/core/trigger/TriggerTypeEnum;ILjava/lang/String;Ljava/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 addressList jobInfo )Lcom/xxl/job/admin/core/model/XxlJobInfo; finalFailRetryCount group *Lcom/xxl/job/admin/core/model/XxlJobGroup; shardingParam [I StackMapTabletu ª isNumeric (Ljava/lang/String;)Z result e !Ljava/lang/NumberFormatException; str 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;>;vw/x 4; 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; Ljava/lang/Exception; runResult runResultSBf 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 y z{ |}~ 3>>>>>>>>>>>> trigger fail, jobId invalidï¼jobId={}
t u / ¯ ° w ½ ¡ ¢£ ¤ ¶ · java/lang/NumberFormatException ¥v ¦ » § ¨ ©ª &com/xxl/job/admin/core/model/XxlJobLog « ¬ java/util/Date ®¯ °±² ³´ +>>>>>>>>>>> xxl-job trigger start, jobId:{} ¬µ¶ · ¸ 'com/xxl/job/core/biz/model/TriggerParam ¹ º » ¼ ½ ¾ ¿ ÀÁ Âà ĵ ÅÁ Æ Ç È É Êà ËÁ Ì Í ÎÏ java/lang/String ÐÑÒ ÓÔ Õ "com/xxl/job/core/biz/model/ReturnT Ö× jobconf_trigger_address_emptyØ Ùª Ú Ò Ó java/lang/StringBuffer jobconf_trigger_type ÛÜ ï¼x Ý <br> jobconf_trigger_admin_adressÞ ß jobconf_trigger_exe_regtype à 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> æ ç è é ê ëì )>>>>>>>>>>> xxl-job trigger end, jobId:{}í îïð ñò java/lang/Exception O>>>>>>>>>>> xxl-job trigger error, please check if the executor[{}] is running. óôõ ãö <br>addressï¼ <br>codeï¼
|
<br>msgï¼ ÷ ,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; trim ()Ljava/lang/String; length setAddressType (I)V setAddressList split '(Ljava/lang/String;)[Ljava/lang/String; '(Ljava/lang/String;)Ljava/lang/Integer; intValue SHARDING_BROADCAST getExecutorRouteStrategy 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 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;)J ()J java/lang/Long (J)Ljava/lang/Long; debug getExecutorHandler setExecutorHandler getExecutorParam setExecutorParams setExecutorBlockStrategy getExecutorTimeout setExecutorTimeout setLogId (J)V getTriggerTime ()Ljava/util/Date; getTime setLogDateTime 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/job/core/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 +(Lcom/xxl/job/admin/core/model/XxlJobLog;)I 0com/xxl/job/admin/core/scheduler/XxlJobScheduler 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/job/core/util/ThrowableUtil )(Ljava/lang/Throwable;)Ljava/lang/String; setMsg org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; !
|
/ *· ± b 9¸ ¶ ¹ :Ç ² ¸ ¹ ±Æ
|
¶ § ¶
|
6¸ ¶ ¶ ¹ :Æ ¶ ¶ ¶ ¶ ¶ : -Æ G-¶ :
|
|
¾ 8
|
2¸ .
|
2¸ $¼
|
:
|
2¸ ¶ O
|
2¸ ¶ O² ¶ ¸ ¦ N¶ Æ F¶ ¹ 9 Ç 46
|
|
¶ ¹ ¢ +
|
¶ ¹ ¸
|
§ÿا ' Ç ¼
|
YOYO: + . .¸ ± n 1 2 3 ! 4 " 6 ' 7 . 9 = : O = _ > e ? o C r D v E ~ F G H ¬ I º L Ë M ã O õ P O S T& V8 Y z ~ <
|
æ +
|
9 9 9 9 ¡ 9 ¢ ¡ 9 £ ¡ + ¤ ¥ = ü ¦ O ê § ¨ r Ç © ª « # ü " ¬ Dý 3 ü J ®ü +ú *
|
¯ ° k *¸ ¶ <¬L¬
|
] ^
|
_ ` ± ² ³ ´ ¡ « J µ
|
¶ · [ x+¶ ² ¸ !:+¶ ¸ :² ¦ ¸ "¶ #¸ "¶ #§ :» $Y· %: +¶ ¶ & +¶ '¶ ( » )Y· *¶ +¸ ¶ , ¹ - X² . ¶ /¸ 0¹ 1 » 2Y· 3:
|
|
+¶ '¶ 4
|
+¶ 5¶ 6
|
+¶ 7¶ 8
|
+¶ ¶ 9
|
+¶ :¶ ;
|
¶ /¶ <
|
¶ =¶ >¶ ?
|
+¶ @¶ A
|
+¶ B¶ C
|
+¶ D¶ >¶ E
|
¶ F
|
¶ G: : *¶ Æ r*¶ ¹ f² ¦ 6*¶ ¹ ¢ *¶ ¹ H À I: § N*¶ ¹ H À I: § <¶ J
|
*¶ ¶ K: ¶ L È ! ¶ NÀ I: § » MYôO¸ P· Q: : Æ
|
¸ R: § » MYô· Q: » SY· T:U¸ P¶ VW¶ V-¶ X¶ VWY¶ VZ¸ P¶ VW¶ V¸ [¶ VWY¶ V\¸ P¶ VW¶ V*¶ ] ^¸ P§ _¸ P¶ VWY¶ V`¸ P¶ VW¶ V*¶ ¶ aWY¶ Vb¸ P¶ VW¶ V¶ c¶ VWÆ "» dY· ef¶ g¶ gh¶ g¶ i¶ VWY¶ Vj¸ P¶ VW¶ V¶ k¶ VWY¶ Vl¸ P¶ VW¶ V+¶ :¶ mWY¶ Vn¸ P¶ VW¶ V ¶ mW» dY· eo¶ gp¸ P¶ gq¶ g¶ i¶ V Æ % ¶ rÆ » dY· e ¶ r¶ gs¶ g¶ i§ t¶ V ¶ rÆ ¶ r§ t¶ VW ¶ u +¶ 5¶ v +¶ 7¶ w ¶ x ¶ y ¶ L¶ z ¶ {¶ |¸ ¶ , ¹ } W² ~ ¶ /¸ 0¹ 1 ± ö = o p q 6 t ? u H v Q w ] x k y } | } ~ ¡ ª ³ ½ Ê Ó
Ü è ï ö ù ü % 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+¸ N-*¹ M§ N² +-¹ » MYô-¸ · QM» SY» dY· ep¸ P¶ gW¶ g¶ i·
N-¶ V+¶ VW-¶ V,¶ L¶ mW-¶ V,¶ r¶ VW,-¶ {¶ ,° 6 Î Ð Ñ Õ Ò Ó Ô . × M Ø X Ù f Ú t Ü | Ý > Ô Õ ² Ö ~ À Á ~ Â ¡ | × Ä M 1 Ø Ç È | × É « ÿ Ï Ì Ð Ù Ú Û Ü ! ¸ ³ ± Ý Þ
|
