diff --git a/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java b/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java
index 59ac91c38..419535675 100644
--- a/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java
+++ b/ControlPlatform/driver-layer/drivers/huawei/src/main/java/com/cmcc/cmhi/huawei/impl/HuaweiNetconfSpeaker.java
@@ -98,6 +98,7 @@ public class HuaweiNetconfSpeaker implements DataTreeChangeListener<ConnectorInf
         InstanceIdentifier<ConnectorInfo> connectPath = InstanceIdentifier.create(ConnectorInfo.class);
         final DataTreeIdentifier<ConnectorInfo> dataTreeIdentifier = new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION, connectPath);
         configurationReg = dataBroker.registerDataTreeChangeListener(dataTreeIdentifier, this);
+        LOG.info("HuaweiNetconfSpeaker Session Initiated");
     }
 
 
@@ -105,9 +106,7 @@ public class HuaweiNetconfSpeaker implements DataTreeChangeListener<ConnectorInf
         /**create netconf node with connect device information */
         final NetconfNodeBuilder netconfNodeBuilder = new NetconfNodeBuilder();
         netconfNodeBuilder.setHost(new Host(new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress(connectDevice.getIp().getIpv4Address())))
-                .setPort(new PortNumber(connectDevice.getPort().getValue()))
-                .setTcpOnly(true)
-                .setSchemaless(true);
+                .setPort(new PortNumber(connectDevice.getPort().getValue()));
         String username = connectDevice.getUserName();
         String password = connectDevice.getPassword();
         if (Strings.isNullOrEmpty(username) || Strings.isNullOrEmpty(password)) {
@@ -259,10 +258,12 @@ public class HuaweiNetconfSpeaker implements DataTreeChangeListener<ConnectorInf
             readInfoFromDevice(nodeId);
         }, 0, 10000, TimeUnit.MILLISECONDS);
         if (Objects.nonNull(threads.get(nodeId))) {
+            LOG.info("remove exist pool in thread map");
             if (!threads.get(nodeId).isShutdown()) {
                 threads.get(nodeId).shutdownNow();
             }
         }
+        LOG.info("put pool in thread map with key {}",nodeId);
         threads.put(nodeId, pool);
     }