supeng 11 ヶ月 前
コミット
5863bae30a

+ 2 - 0
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/RecallService.java

@@ -61,8 +61,10 @@ public class RecallService implements ApplicationContextAware {
         CountDownLatch cdl = new CountDownLatch(strategies.size());
         List<Future<RecallResult.RecallData>> recallResultFutures = new ArrayList<>();
         for (final RecallStrategy strategy : strategies) {
+            log.info("supply flowpool strategy = {}", strategy.getClass().toString());
             Future<RecallResult.RecallData> future = pool.submit(() -> {
                 List<Video> result = strategy.recall(param);
+                log.info("supply flowpool strategy = {}, result = {}", strategy.getClass().toString(), result);
                 cdl.countDown();
                 return new RecallResult.RecallData(strategy.pushFrom(), result);
             });

+ 1 - 1
recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/service/recall/strategy/FlowPoolWithLevelSupplyRecallStrategy.java

@@ -28,7 +28,7 @@ public class FlowPoolWithLevelSupplyRecallStrategy extends AbstractFlowPoolWithL
     Pair<String, String> flowPoolKeyAndLevel(RecallParam param) {
         //# 1. 获取流量池各层级分发概率权重
         Map<String, Double> levelWeightMap = flowPoolConfigService.getLevelWeight();
-
+        log.info("supply flowpool levelWeightMap = {}", levelWeightMap);
         // 2. 判断各层级是否有视频需分发
         List<LevelWeight> availableLevels = new ArrayList<>();
         for (Map.Entry<String, Double> entry : levelWeightMap.entrySet()) {