diff --git a/src/main/java/cn/ac/iie/common/FlowWriteConfig.java b/src/main/java/cn/ac/iie/common/FlowWriteConfig.java
index 66e124d..97db894 100644
--- a/src/main/java/cn/ac/iie/common/FlowWriteConfig.java
+++ b/src/main/java/cn/ac/iie/common/FlowWriteConfig.java
@@ -49,17 +49,6 @@ public class FlowWriteConfig {
 
     public static final String IP_LIBRARY = FlowWriteConfigurations.getStringProperty(0, "ip.library");
 
-
-    /***
-     * Redis
-     */
-    public static final String REDIS_IP = "redis.ip";
-    public static final String REDIS_PORT = "redis.port";
-    public static final String REDIS_TIMEOUT = "redis.timeout";
-    public static final String REDIS_POOL_MAXACTIVE = "redis.pool.maxActive";
-    public static final String REDIS_POOL_MAXIDLE = "redis.pool.maxIdle";
-    public static final String REDIS_POOL_MAXWAIT = "redis.pool.maxWait";
-    public static final String REDIS_POOL_TESTONBORROW = "redis.pool.testOnBorrow";
-    public static final String REDIS_POOL_TESTONRETURN = "redis.pool.testOnReturn";
+    
 
 }
\ No newline at end of file
diff --git a/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java b/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java
index 80ecdb8..58859ae 100644
--- a/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java
+++ b/src/main/java/cn/ac/iie/topology/LogFlowWriteTopology.java
@@ -1,6 +1,7 @@
 package cn.ac.iie.topology;
 
 
+import cn.ac.iie.bean.CollectProtocolRecordLog;
 import cn.ac.iie.bolt.NtcLogSendBolt;
 import cn.ac.iie.bolt.collectProtocol.CollectCompletedBolt;
 import cn.ac.iie.bolt.radius.RadiusCompletionBolt;
@@ -76,7 +77,7 @@ public class LogFlowWriteTopology {
                 builder.setBolt("NtcLogSendBolt", new NtcLogSendBolt(), FlowWriteConfig.KAFKA_BOLT_PARALLELISM).localOrShuffleGrouping("RadiusCompletionBolt");
                 break;
 
-            case "COLLECT-CONNECTION-RECORD-LOG":
+            case "COLLECT-PROTOCOL-RECORD-LOG":
                 builder.setBolt("CollectCompletedBolt", new CollectCompletedBolt(), FlowWriteConfig.DATACENTER_BOLT_PARALLELISM).localOrShuffleGrouping("LogFlowWriteSpout");
                 builder.setBolt("NtcLogSendBolt", new NtcLogSendBolt(), FlowWriteConfig.KAFKA_BOLT_PARALLELISM).localOrShuffleGrouping("CollectCompletedBolt");
                 break;