-
Type:
Bug
-
Status: Closed
-
Priority:
Minor
-
Resolution: Fixed
-
Affects Version/s: 2.0.0, 1.0.3, 1.2.3, 2.1.0
-
Component/s: storm-core
-
Labels:
-
Environment:storm-core:1.0.3
org.apache.storm.utils.Utils#getGlobalStreamId has wrong parameters order:
public static GlobalStreamId getGlobalStreamId(String streamId, String componentId) {
if (componentId == null)
return new GlobalStreamId(streamId, componentId);
}
but GlobalStreamId constructor is: public GlobalStreamId(
String componentId,
String streamId)
so i think the nice code is:
public static GlobalStreamId getGlobalStreamId(String streamId, String componentId) {
if (streamId == null)
return new GlobalStreamId(componentId, streamId);
}