Skip to content
This repository was archived by the owner on Jun 16, 2023. It is now read-only.

Break the infinite loop #632

Open
MichealShin wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Break the infinite loop #632

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions jstorm-core/src/main/java/com/alibaba/jstorm/transactional/TransactionTopologyBuilder.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -210,4 +210,4 @@ protected BoltDeclarer grouping(String componentId, String streamId, Grouping gr
return super.grouping(componentId, streamId, grouping);
}
}
}
}