diff --git a/fate-serving-admin/src/main/java/com/webank/ai/fate/serving/admin/services/provider/ValidateServiceProvider.java b/fate-serving-admin/src/main/java/com/webank/ai/fate/serving/admin/services/provider/ValidateServiceProvider.java index 9a08b3243..8cfdf96d7 100644 --- a/fate-serving-admin/src/main/java/com/webank/ai/fate/serving/admin/services/provider/ValidateServiceProvider.java +++ b/fate-serving-admin/src/main/java/com/webank/ai/fate/serving/admin/services/provider/ValidateServiceProvider.java @@ -119,6 +119,9 @@ public Object inference(Context context, InboundPackage data) throws Exception { if (StringUtils.isNotBlank(serviceId)) { inferenceRequest.setServiceId(serviceId); } + if(params.get("applyId")!=null){ + inferenceRequest.setApplyId(params.get("applyId").toString()); + } for (Map.Entry entry : featureData.entrySet()) { inferenceRequest.getFeatureData().put(entry.getKey(), entry.getValue()); diff --git a/fate-serving-core/src/main/java/com/webank/ai/fate/serving/core/bean/GrpcConnectionPool.java b/fate-serving-core/src/main/java/com/webank/ai/fate/serving/core/bean/GrpcConnectionPool.java index 914342d05..3b7741d24 100644 --- a/fate-serving-core/src/main/java/com/webank/ai/fate/serving/core/bean/GrpcConnectionPool.java +++ b/fate-serving-core/src/main/java/com/webank/ai/fate/serving/core/bean/GrpcConnectionPool.java @@ -219,12 +219,11 @@ public synchronized ManagedChannel createManagedChannel(String ip, int port, Net } else { channelBuilder.usePlaintext(); } - return channelBuilder.build(); - } catch (SSLException e) { - throw new SecurityException(e); - } catch (Exception e) { - e.printStackTrace(); + } + catch (Exception e) { + logger.error("create channel error : " ,e); + //e.printStackTrace(); } return null; }