@@ -68,7 +68,7 @@ public void start() {
6868 pubStr .append (logPublisher (publisher )).append (";" );
6969 }
7070 }
71- LOGGER .info ("[Datum] dataInfoId= {}, version= {}, dataCenter= {}, publishers= [{}]" , dataInfoId ,
71+ LOGGER .info ("[Datum]{},{},{},[{}]" , dataInfoId ,
7272 data .getVersion (), dataCenter , pubStr .toString ());
7373 }
7474 int pubCount = datumMap .values ().stream ().map (Datum ::getPubMap )
@@ -82,16 +82,15 @@ public void start() {
8282 } catch (Throwable t ) {
8383 LOGGER .error ("[CacheDigestTask] cache digest error" , t );
8484 }
85- }, 30 , 300 , TimeUnit .SECONDS );
85+ }, 30 , 600 , TimeUnit .SECONDS );
8686 }
8787
8888 private String logPublisher (Publisher publisher ) {
8989 if (publisher != null ) {
9090 URL url = publisher .getSourceAddress ();
9191 String urlStr = url != null ? url .getAddressString () : "null" ;
92- return String .format ("registerId=%s, registerTimestamp=%s, host=%s, version=%s" ,
93- publisher .getRegisterId (), publisher .getRegisterTimestamp (), urlStr ,
94- publisher .getVersion ());
92+ return String .format ("%s,%s,%s,%s" , publisher .getRegisterId (),
93+ publisher .getRegisterTimestamp (), urlStr , publisher .getVersion ());
9594 }
9695 return "" ;
9796 }
0 commit comments