|
|
@@ -102,18 +102,13 @@ public class PAIScorerV2 extends AbstractScorer {
|
|
|
long submitTime = System.currentTimeMillis();
|
|
|
for (List<AdRankItem> batch : batches) {
|
|
|
futures.add(executor.submit(() -> {
|
|
|
- long queueWaitTime = System.currentTimeMillis() - submitTime;
|
|
|
- long batchStartTime = System.currentTimeMillis();
|
|
|
+
|
|
|
try {
|
|
|
multipleCtrScore(batch, userFeatureMap, sceneFeatureMap, model);
|
|
|
} catch (Exception e) {
|
|
|
LOGGER.error("Error during multipleCtrScore batch execution", e);
|
|
|
}
|
|
|
- long batchExecuteTime = System.currentTimeMillis() - batchStartTime;
|
|
|
- if (queueWaitTime > 100) {
|
|
|
- LOGGER.error("PAIScorerV2 batch queue wait too long batchSize={} queueWaitTime={}ms executeTime={}ms",
|
|
|
- batch.size(), queueWaitTime, batchExecuteTime);
|
|
|
- }
|
|
|
+
|
|
|
return batch;
|
|
|
}));
|
|
|
}
|