[INLONG-5752][Manager] Change the text type to medium text to avoid saving long data failed

inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/SinkOperatorFactory.java

@@ -23,7 +23,6 @@
 import org.springframework.stereotype.Service;
 
 import java.util.List;
-import java.util.Optional;
 
 /**
  * Factory for {@link StreamSinkOperator}.
@@ -38,14 +37,11 @@ public class SinkOperatorFactory {
      * Get a sink operator instance via the given sinkType
      */
     public StreamSinkOperator getInstance(String sinkType) {
-        Optional<StreamSinkOperator> instance = sinkOperatorList.stream()
+        return sinkOperatorList.stream()
                 .filter(inst -> inst.accept(sinkType))
-                .findFirst();
-        if (!instance.isPresent()) {
-            throw new BusinessException(ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT,
-                    String.format(ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT.getMessage(), sinkType));
-        }
-        return instance.get();
+                .findFirst()
+                .orElseThrow(() -> new BusinessException(ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT,
+                        String.format(ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT.getMessage(), sinkType)));
     }
 
 }

inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java

@@ -150,7 +150,7 @@ public Map<String, List<StreamSource>> getSourcesMap(InlongGroupInfo groupInfo,
         Map<String, List<StreamSource>> result;
 
         // if the group mode is LIGHTWEIGHT, just get all related stream sources
-        List<StreamSource> streamSources = this.listSource(groupInfo.getInlongGroupId(), null);
+        List<StreamSource> streamSources = this.listSource(groupId, null);
         if (InlongConstants.LIGHTWEIGHT_MODE.equals(groupInfo.getLightweight())) {
             result = streamSources.stream()
                     .collect(Collectors.groupingBy(StreamSource::getInlongStreamId, HashMap::new,

inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongGroupController.java

@@ -75,7 +75,7 @@ public Response<InlongGroupInfo> get(@PathVariable String groupId) {
     }
 
     @RequestMapping(value = "/group/list", method = RequestMethod.POST)
-    @ApiOperation(value = "Get inlong group list by paginating")
+    @ApiOperation(value = "List inlong groups by paginating")
     public Response<PageResult<InlongGroupBriefInfo>> listBrief(@RequestBody InlongGroupPageRequest request) {
         request.setCurrentUser(LoginUserUtils.getLoginUser().getName());
         request.setIsAdminRole(LoginUserUtils.getLoginUser().getRoles().contains(UserTypeEnum.ADMIN.name()));

inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java

@@ -84,15 +84,15 @@ public Response<InlongStreamResponse> get(@RequestParam String groupId, @Request
     }
 
     @RequestMapping(value = "/stream/list", method = RequestMethod.POST)
-    @ApiOperation(value = "Get inlong stream brief info by paginating")
+    @ApiOperation(value = "List inlong stream briefs by paginating")
     public Response<PageResult<InlongStreamBriefInfo>> listByCondition(@RequestBody InlongStreamPageRequest request) {
         request.setCurrentUser(LoginUserUtils.getLoginUser().getName());
         request.setIsAdminRole(LoginUserUtils.getLoginUser().getRoles().contains(UserRoleCode.ADMIN));
         return Response.success(streamService.listBrief(request));
     }
 
     @RequestMapping(value = "/stream/listAll", method = RequestMethod.POST)
-    @ApiOperation(value = "Get inlong stream with all sources and sinks by paginating")
+    @ApiOperation(value = "List inlong streams with sources and sinks by paginating")
     public Response<PageResult<InlongStreamInfo>> listAllWithGroupId(@RequestBody InlongStreamPageRequest request) {
         request.setCurrentUser(LoginUserUtils.getLoginUser().getName());
         request.setIsAdminRole(LoginUserUtils.getLoginUser().getRoles().contains(UserRoleCode.ADMIN));

inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java

@@ -64,7 +64,7 @@ public Response<StreamSink> get(@PathVariable Integer id) {
     }
 
     @RequestMapping(value = "/sink/list", method = RequestMethod.GET)
-    @ApiOperation(value = "Get stream sink list by paginating")
+    @ApiOperation(value = "List stream sinks by paginating")
     public Response<PageResult<? extends StreamSink>> listByCondition(SinkPageRequest request) {
         return Response.success(sinkService.listByCondition(request));
     }

inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSourceController.java

@@ -64,7 +64,7 @@ public Response<StreamSource> get(@PathVariable Integer id) {
     }
 
     @RequestMapping(value = "/source/list", method = RequestMethod.GET)
-    @ApiOperation(value = "Get stream source list by paginating")
+    @ApiOperation(value = "List stream sources by paginating")
     public Response<PageResult<? extends StreamSource>> listByCondition(SourcePageRequest request) {
         return Response.success(sourceService.listByCondition(request));
     }