gosonzhang commented on code in PR #7424:
URL: https://github.com/apache/inlong/pull/7424#discussion_r1118209819
##########
inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java:
##########
@@ -720,6 +725,24 @@ public void logicDeleteDlqOrRlq(String groupId, String
topicName, String operato
LOGGER.info("success to logic delete dlq or rlq by groupId={},
topicName={}", groupId, topicName);
}
+ @Override
+ public List<StreamField> parseFields(String fieldsJson) {
+ try {
+ Map<String, String> fieldsMap = objectMapper.readValue(fieldsJson,
+ new TypeReference<Map<String, String>>() {
+ });
+ return fieldsMap.keySet().stream().map(fieldName -> {
+ StreamField field = new StreamField();
+ field.setFieldName(fieldName);
+ field.setFieldType(fieldsMap.get(fieldName));
+ return field;
+ }).collect(Collectors.toList());
+ } catch (Exception e) {
+ LOGGER.error("parse inlong stream fields error", e);
+ throw new JsonException("parse inlong stream fields error");
Review Comment:
The corresponding error code needs to be added
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
