change log

Signed-off-by: forgive_dengkai <forgive_dengkai@163.com>
FederatedAI · Aug 7, 2023 · 398e2ec · 398e2ec
1 parent 784a200
commit 398e2ec
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/java/osx/osx-broker/src/main/java/com/osx/broker/consumer/UnaryConsumer.java b/java/osx/osx-broker/src/main/java/com/osx/broker/consumer/UnaryConsumer.java
@@ -162,7 +162,7 @@ public static class LongPullingHold {
         long needOffset;
 
         public  void  answer(Osx.Outbound  consumeResponse){
-            logger.info("============ answer long pulling========");
+
 
             if(streamObserver!=null) {
 

diff --git a/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/CommandClient.java b/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/CommandClient.java
@@ -65,7 +65,7 @@ public Command.CommandResponse call(CommandURI commandUri, BaseProto... baseProt
                 .addAllArgs(Arrays.stream(baseProtos).
                         map((element) -> ((AbstractMessageLite) element.toProto()).toByteString()).collect(Collectors.toList()))
                 .build();
-        logger.info("===call {} {} id {}", erEndpoint.host, erEndpoint.port, id);
+
 
         ManagedChannel managedChannel = buildManagedChannel(erEndpoint.host, erEndpoint.port);
         CommandServiceGrpc.CommandServiceBlockingStub stub = CommandServiceGrpc.newBlockingStub(managedChannel);

diff --git a/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/PushEventHandler.java b/java/osx/osx-broker/src/main/java/com/osx/broker/eggroll/PushEventHandler.java
@@ -124,7 +124,7 @@ protected  void  handleMessage(MessageExt messageExt){
             putBatchSinkPushReqSO.onNext(tbBatch);
 
         }catch(Exception e){
-            logger.error("======handle msg error : "+ messageExt.getTopic(),e);
+            logger.error("handle msg error : "+ messageExt.getTopic(),e);
             if(backBlockingStub!=null) {
                 Osx.Inbound.Builder inboundBuilder = TransferUtil.buildInbound(provider,desPartyId, srcPartyId, TargetMethod.PRODUCE_MSG.name(),
                         backTopic, MessageFlag.ERROR, sessionId, ErrorMessageUtil.buildRemoteRpcErrorMsg(1343,"kkkkk").getBytes());

diff --git a/java/osx/osx-broker/src/test/java/com/osx/broker/test/grpc/NewFateTest.java b/java/osx/osx-broker/src/test/java/com/osx/broker/test/grpc/NewFateTest.java
@@ -91,7 +91,7 @@ public void testUnaryCall(byte[] data){
 
     @Test
     public void testStream(){
-        System.err.println("==========================");
+
         io.grpc.stub.StreamObserver<org.ppc.ptp.Osx.Inbound>  reqSb = stub.transport(new StreamObserver<Osx.Outbound>() {
             @Override
             public void onNext(Osx.Outbound outbound) {