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;
}
/**