Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
2.0.0, 1.0.3, 1.2.3, 2.1.0
-
storm-core:1.0.3
Description
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);
}