Skip to content

Commit 649c68b

Browse files
Merge pull request #103 from FederatedAI/develop
Develop
2 parents 3893aad + 900d7d8 commit 649c68b

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
lines changed

fate-serving-admin/src/main/java/com/webank/ai/fate/serving/admin/services/provider/ValidateServiceProvider.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -119,6 +119,9 @@ public Object inference(Context context, InboundPackage data) throws Exception {
119119
if (StringUtils.isNotBlank(serviceId)) {
120120
inferenceRequest.setServiceId(serviceId);
121121
}
122+
if(params.get("applyId")!=null){
123+
inferenceRequest.setApplyId(params.get("applyId").toString());
124+
}
122125

123126
for (Map.Entry<String, Object> entry : featureData.entrySet()) {
124127
inferenceRequest.getFeatureData().put(entry.getKey(), entry.getValue());

fate-serving-core/src/main/java/com/webank/ai/fate/serving/core/bean/GrpcConnectionPool.java

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -219,12 +219,11 @@ public synchronized ManagedChannel createManagedChannel(String ip, int port, Net
219219
} else {
220220
channelBuilder.usePlaintext();
221221
}
222-
223222
return channelBuilder.build();
224-
} catch (SSLException e) {
225-
throw new SecurityException(e);
226-
} catch (Exception e) {
227-
e.printStackTrace();
223+
}
224+
catch (Exception e) {
225+
logger.error("create channel error : " ,e);
226+
//e.printStackTrace();
228227
}
229228
return null;
230229
}

0 commit comments

Comments
 (0)