[incubator-dolphinscheduler] branch dev updated: NettyDecoder class decode method switch case remove break (#3035)

[technoboy]

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

technoboy pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 1eb8fb6  NettyDecoder class decode method switch case remove break 
(#3035)
1eb8fb6 is described below

commit 1eb8fb6db33af4b644492a9fb0b0348d7de14407
Author: qiaozhanwei <qiaozhan...@outlook.com>
AuthorDate: Fri Jul 10 11:10:13 2020 +0800

    NettyDecoder class decode method switch case remove break (#3035)
---
 .../java/org/apache/dolphinscheduler/remote/codec/NettyDecoder.java  | 5 -----
 1 file changed, 5 deletions(-)

diff --git 
a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/codec/NettyDecoder.java
 
b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/codec/NettyDecoder.java
index 09f97d6..a690222 100644
--- 
a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/codec/NettyDecoder.java
+++ 
b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/codec/NettyDecoder.java
@@ -55,19 +55,15 @@ public class NettyDecoder extends 
ReplayingDecoder<NettyDecoder.State> {
             case MAGIC:
                 checkMagic(in.readByte());
                 checkpoint(State.COMMAND);
-                break;
             case COMMAND:
                 commandHeader.setType(in.readByte());
                 checkpoint(State.OPAQUE);
-                break;
             case OPAQUE:
                 commandHeader.setOpaque(in.readLong());
                 checkpoint(State.BODY_LENGTH);
-                break;
             case BODY_LENGTH:
                 commandHeader.setBodyLength(in.readInt());
                 checkpoint(State.BODY);
-                break;
             case BODY:
                 byte[] body = new byte[commandHeader.getBodyLength()];
                 in.readBytes(body);
@@ -79,7 +75,6 @@ public class NettyDecoder extends 
ReplayingDecoder<NettyDecoder.State> {
                 out.add(packet);
                 //
                 checkpoint(State.MAGIC);
-                break;
             default:
                 logger.warn("unknown decoder state {}", state());
         }