diff --git a/jstorm-core/src/main/java/com/alibaba/jstorm/transactional/TransactionTopologyBuilder.java b/jstorm-core/src/main/java/com/alibaba/jstorm/transactional/TransactionTopologyBuilder.java
index c16f32e83..344a053f9 100644
--- a/jstorm-core/src/main/java/com/alibaba/jstorm/transactional/TransactionTopologyBuilder.java
+++ b/jstorm-core/src/main/java/com/alibaba/jstorm/transactional/TransactionTopologyBuilder.java
@@ -90,7 +90,7 @@ public SpoutDeclarer setSpout(String id, ITransactionSpoutExecutor spout, Number
     }
 
     public SpoutDeclarer setSpout(String id, ITransactionSpoutExecutor spout, Number parallelismHint, boolean isSchedule) {
-        return setSpout(id, spout, parallelismHint, isSchedule);
+        return setSpout(id, (IRichSpout) spout, parallelismHint, isSchedule);
     }
 
     private SpoutDeclarer setSpout(String id, IRichSpout spout, Number parallelismHint, boolean isSchedule) {
@@ -124,7 +124,7 @@ public BoltDeclarer setBolt(String id, ITransactionBoltExecutor bolt) {
     }
 
     public BoltDeclarer setBolt(String id, ITransactionBoltExecutor bolt, Number parallelismHint) {
-        return setBolt(id, bolt, parallelismHint);
+        return setBolt(id, (IRichBolt) bolt, parallelismHint);
     }
 
     @Override
@@ -210,4 +210,4 @@ protected BoltDeclarer grouping(String componentId, String streamId, Grouping gr
             return super.grouping(componentId, streamId, grouping);
         }
     }
-}
\ No newline at end of file
+}