[INLONG-2596][TubeMQ] fix param error and add override annotation (#2595

)
apache · Feb 19, 2022 · 9f3a951 · 9f3a951
1 parent 720f68c
commit 9f3a951
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/...q/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/common/QueryMetaResult.java b/...q/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/common/QueryMetaResult.java
@@ -37,10 +37,12 @@ public QueryMetaResult(int errCode, String errInfo) {
         super(errCode, errInfo);
     }
 
+    @Override
     public void setFailResult(int errCode, final String errMsg) {
         super.setFailResult(errCode, errMsg);
     }
 
+    @Override
     public void setFailResult(final String errMsg) {
         super.setFailResult(errMsg);
     }

diff --git a/...mq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/PartitionExt.java b/...mq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/PartitionExt.java
@@ -80,12 +80,12 @@ public long procConsumeResult(boolean isFilterConsume) {
      * @param isReqEscLimit   if the rsplimitDlt is ignored in current consume
      * @param rsplimitDlt     max offset of the current consume
      * @param lastDataDlt     offset of the last data fetch
-     * @param isRRequireSlow  if the server requires slow down
+     * @param isRequireSlow  if the server requires slow down
      * @return message size per minute
      */
     public long procConsumeResult(boolean isFilterConsume, int reqProcType, int errCode,
                                   int msgSize, boolean isReqEscLimit, long rsplimitDlt,
-                                  long lastDataDlt, boolean isRRequireSlow) {
+                                  long lastDataDlt, boolean isRequireSlow) {
         if (lastDataDlt >= 0) {
             this.lastDataRdDlt = lastDataDlt;
         }
@@ -121,7 +121,7 @@ public long procConsumeResult(boolean isFilterConsume, int reqProcType, int errC
             }
             if (errCode == TErrCodeConstants.SUCCESS) {
                 if (isFilterConsume && filterCtrlItem.getFreqLtInMs() >= 0) {
-                    if (isRRequireSlow) {
+                    if (isRequireSlow) {
                         return this.filterCtrlItem.getZeroCnt();
                     } else {
                         return this.filterCtrlItem.getFreqLtInMs();

diff --git a/inlong-tubemq/tubemq-manager/pom.xml b/inlong-tubemq/tubemq-manager/pom.xml
@@ -176,7 +176,7 @@
                     </descriptors>
                     <archive>
                         <manifest>
-                            <mainClass>com.cyy.MvnPackageApplication</mainClass>
+                            <mainClass>org.apache.inlong.tubemq.manager.TubeMQManager</mainClass>
                         </manifest>
                     </archive>
                 </configuration>