You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by et...@apache.org on 2020/03/19 14:05:06 UTC

[storm] branch 1.x-branch updated: [STORM-2483] misnamed parameters

This is an automated email from the ASF dual-hosted git repository.

ethanli pushed a commit to branch 1.x-branch
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/1.x-branch by this push:
     new e7b1c09  [STORM-2483] misnamed parameters
     new 514dd9a  Merge pull request #3230 from nd368/1.x-branch
e7b1c09 is described below

commit e7b1c09cf317738755c97bd41d820d94176b550d
Author: nathanday123 <na...@hotmail.co.uk>
AuthorDate: Wed Mar 18 10:04:21 2020 +0000

    [STORM-2483] misnamed parameters
---
 storm-core/src/jvm/org/apache/storm/utils/Utils.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/storm-core/src/jvm/org/apache/storm/utils/Utils.java b/storm-core/src/jvm/org/apache/storm/utils/Utils.java
index c5b6f39..a31d179 100644
--- a/storm-core/src/jvm/org/apache/storm/utils/Utils.java
+++ b/storm-core/src/jvm/org/apache/storm/utils/Utils.java
@@ -1558,11 +1558,11 @@ public class Utils {
         return number & Integer.MAX_VALUE;
     }
 
-    public static GlobalStreamId getGlobalStreamId(String streamId, String componentId) {
-        if (componentId == null) {
-            return new GlobalStreamId(streamId, DEFAULT_STREAM_ID);
+    public static GlobalStreamId getGlobalStreamId(String componentId, String streamId) {
+        if (streamId == null) {
+            return new GlobalStreamId(componentId, DEFAULT_STREAM_ID);
         }
-        return new GlobalStreamId(streamId, componentId);
+        return new GlobalStreamId(componentId, streamId);
     }
 
     public static RuntimeException wrapInRuntime(Exception e){