|
@@ -95,8 +95,6 @@ public class FeatureV2Client {
|
|
|
// 小请求不拆包：保持原行为
|
|
// 小请求不拆包：保持原行为
|
|
|
if (protos.size() <= BATCH_SIZE) {
|
|
if (protos.size() <= BATCH_SIZE) {
|
|
|
Map<String, String> result = multiGetFeatureWithRetry(protos, 0);
|
|
Map<String, String> result = multiGetFeatureWithRetry(protos, 0);
|
|
|
- log.info("multiGetFeature: end, protos.size={}, batchSize={}, batchCount=1, result.size={}, cost={}",
|
|
|
|
|
- protos.size(), BATCH_SIZE, result != null ? result.size() : 0, System.currentTimeMillis() - startTime);
|
|
|
|
|
return result;
|
|
return result;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -139,7 +137,6 @@ public class FeatureV2Client {
|
|
|
* @return 特征数据 Map
|
|
* @return 特征数据 Map
|
|
|
*/
|
|
*/
|
|
|
private Map<String, String> multiGetFeatureWithRetry(List<FeatureKeyProto> protos, int attemptCount) {
|
|
private Map<String, String> multiGetFeatureWithRetry(List<FeatureKeyProto> protos, int attemptCount) {
|
|
|
- log.warn("multiGetFeatureWithRetry: start, attempt={}, protos.size={}", attemptCount, protos.size());
|
|
|
|
|
|
|
|
|
|
MultiGetFeatureRequest request = MultiGetFeatureRequest.newBuilder()
|
|
MultiGetFeatureRequest request = MultiGetFeatureRequest.newBuilder()
|
|
|
.addAllFeatureKey(protos)
|
|
.addAllFeatureKey(protos)
|
