(iotdb) branch master updated: IoTV2: Improve create consensus log based on product scenario #14306

[tanxinyu]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 790bc26d4fc IoTV2: Improve create consensus log based on product 
scenario #14306
790bc26d4fc is described below

commit 790bc26d4fc3b05c6e9de7ad6d2d027fb5703188
Author: Peng Junzhi <78788603+peng...@users.noreply.github.com>
AuthorDate: Wed Dec 4 13:09:16 2024 +0800

    IoTV2: Improve create consensus log based on product scenario #14306
---
 .../org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java  | 3 ++-
 .../iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java  | 8 ++++----
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git 
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
 
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
index b6e57f24eb4..5903422a000 100644
--- 
a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
+++ 
b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
@@ -221,7 +221,8 @@ public class PipeConsensusServerImpl {
                     "{}: cannot create consensus pipe between {} and {}",
                     e.getMessage(),
                     thisNode,
-                    peer);
+                    peer,
+                    e);
                 return false;
               }
             })
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java
index 545d068e53a..23db3caa0d7 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java
@@ -67,7 +67,7 @@ public class ConsensusPipeDataNodeDispatcher implements 
ConsensusPipeDispatcher
         throw new PipeException(status.getMessage());
       }
     } catch (Exception e) {
-      LOGGER.warn("Failed to create consensus pipe-{}", pipeName);
+      LOGGER.warn("Failed to create consensus pipe-{}", pipeName, e);
       throw new PipeException("Failed to create consensus pipe", e);
     }
   }
@@ -82,7 +82,7 @@ public class ConsensusPipeDataNodeDispatcher implements 
ConsensusPipeDispatcher
         throw new PipeException(status.getMessage());
       }
     } catch (Exception e) {
-      LOGGER.warn("Failed to start consensus pipe-{}", pipeName);
+      LOGGER.warn("Failed to start consensus pipe-{}", pipeName, e);
       throw new PipeException("Failed to start consensus pipe", e);
     }
   }
@@ -97,7 +97,7 @@ public class ConsensusPipeDataNodeDispatcher implements 
ConsensusPipeDispatcher
         throw new PipeException(status.getMessage());
       }
     } catch (Exception e) {
-      LOGGER.warn("Failed to stop consensus pipe-{}", pipeName);
+      LOGGER.warn("Failed to stop consensus pipe-{}", pipeName, e);
       throw new PipeException("Failed to stop consensus pipe", e);
     }
   }
@@ -114,7 +114,7 @@ public class ConsensusPipeDataNodeDispatcher implements 
ConsensusPipeDispatcher
         throw new PipeException(status.getMessage());
       }
     } catch (Exception e) {
-      LOGGER.warn("Failed to drop consensus pipe-{}", pipeName);
+      LOGGER.warn("Failed to drop consensus pipe-{}", pipeName, e);
       throw new PipeException("Failed to drop consensus pipe", e);
     }
     // Release corresponding receiver's resource