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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new ab6d65c6c [INLONG-3623][InLong] Switch must have default branch for 
check style (#3624)
ab6d65c6c is described below

commit ab6d65c6c01d16b09c0171e27d27226516a4b13a
Author: baomingyu <[email protected]>
AuthorDate: Mon Apr 11 19:24:39 2022 +0800

    [INLONG-3623][InLong] Switch must have default branch for check style 
(#3624)
---
 .../java/org/apache/inlong/audit/source/ServerMessageHandler.java     | 2 ++
 .../java/org/apache/inlong/manager/service/CommonOperateService.java  | 2 ++
 .../singletenant/flink/deserialization/FieldMappingTransformer.java   | 4 ++--
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
index 93f0423a7..483698e79 100644
--- 
a/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
+++ 
b/inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java
@@ -136,6 +136,8 @@ public class ServerMessageHandler extends 
ChannelInboundHandlerAdapter {
             case AUDITREPLY:
                 checkArgument(cmd.hasAuditReply());
                 break;
+            default:
+                channelBuffer = null;
         }
         if (channelBuffer != null) {
             writeResponse(remoteChannel, channelBuffer);
diff --git 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
index ba9a9a432..efc54fa83 100644
--- 
a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
+++ 
b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/CommonOperateService.java
@@ -124,6 +124,8 @@ public class CommonOperateService {
                 }
                 break;
             }
+            default:
+                LOGGER.warn("case warn key {}", key);
         }
         return result;
     }
diff --git 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/deserialization/FieldMappingTransformer.java
 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/deserialization/FieldMappingTransformer.java
index 41c39a97f..fb64df4fa 100644
--- 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/deserialization/FieldMappingTransformer.java
+++ 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/deserialization/FieldMappingTransformer.java
@@ -108,9 +108,9 @@ public class FieldMappingTransformer implements 
Serializable {
                 return CanalJsonSerializationSchema.rowKind2String(kind);
             case MYSQL_METADATA_DATA:
                 return attributes.get(MysqlBinLogData.MYSQL_METADATA_DATA);
+            default:
+                return null;
         }
-
-        return null;
     }
 
     /**

Reply via email to