...
|
...
|
@@ -81,6 +81,7 @@ public class UnionClickCountDayTask { |
|
|
timeoutRetryCount);
|
|
|
Map<String, UnionClickCount> map = new HashMap<>();
|
|
|
|
|
|
long s = System.currentTimeMillis();
|
|
|
int count = 0;
|
|
|
// 当小于结束时间一直执行
|
|
|
while (begin < end) {
|
...
|
...
|
@@ -162,8 +163,10 @@ public class UnionClickCountDayTask { |
|
|
failedCount++;
|
|
|
}
|
|
|
}
|
|
|
logger.info("UnionClickCountDayTask run over data count={}, insert over! success={}, error={}", count, successCount, failedCount);
|
|
|
return "UnionClickCountDayTask run over data count=" + count + ", insert success=" + successCount + ", error=" + failedCount;
|
|
|
long e = System.currentTimeMillis();
|
|
|
long u = e - s;
|
|
|
logger.info("UnionClickCountDayTask run over data count={}, insert over! success={}, error={}, timeUse={}", count, successCount, failedCount, u);
|
|
|
return "UnionClickCountDayTask run over data count=" + count + ", insert success=" + successCount + ", error=" + failedCount+", timseUse="+u;
|
|
|
} finally {
|
|
|
lock.unlock();
|
|
|
}
|
...
|
...
|
|