[GitHub] [inlong] fuweng11 commented on a diff in pull request #7001: [INLONG-6998][Dashboard][Manager] Support ignore deserialization error

[GitBox <gi...@apache.org>]

fuweng11 commented on code in PR #7001:
URL: https://github.com/apache/inlong/pull/7001#discussion_r1055965721


##########
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java:
##########
@@ -514,12 +571,35 @@ public Boolean updateWithoutCheck(InlongStreamRequest request, String operator)
         // update stream fields
         updateField(groupId, streamId, request.getFieldList());
         // update stream extension infos
-        saveOrUpdateExt(groupId, streamId, request.getExtList());
+        List<InlongStreamExtInfo> extList = request.getExtList();
+        extList = packExtParams(request, extList);
+        saveOrUpdateExt(groupId, streamId, extList);
 
         LOGGER.info("success to update inlong stream without check for groupId={} streamId={}", groupId, streamId);
         return true;
     }
 
+    /**
+     * Pack extended attributes into {@link InlongStreamExtInfo} 
+     * @param request the request
+     * @param extList the extList from frontend
+     * @return the packed extParams
+     */
+    private List<InlongStreamExtInfo> packExtParams(InlongStreamRequest request,

Review Comment:
   I don't think additional parameters can be added in this way.If there are more parameters later, the code will become very redundant.



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org