You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2023/04/03 04:50:06 UTC
[inlong] branch master updated: [INLONG-7760][Manager] Fix parse fields failed for streamSink and InlongStream (#7761)
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/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 3e099802d [INLONG-7760][Manager] Fix parse fields failed for streamSink and InlongStream (#7761)
3e099802d is described below
commit 3e099802de76a14e5f8b7cb7b6b008c2e003562f
Author: fuweng11 <76...@users.noreply.github.com>
AuthorDate: Mon Apr 3 12:50:00 2023 +0800
[INLONG-7760][Manager] Fix parse fields failed for streamSink and InlongStream (#7761)
---
.../java/org/apache/inlong/manager/pojo/sink/ParseFieldRequest.java | 4 ++++
.../inlong/manager/web/controller/InlongStreamController.java | 6 ++----
.../apache/inlong/manager/web/controller/StreamSinkController.java | 1 -
3 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ParseFieldRequest.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ParseFieldRequest.java
index 206a4b822..e9e8892dd 100644
--- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ParseFieldRequest.java
+++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ParseFieldRequest.java
@@ -19,14 +19,18 @@ package org.apache.inlong.manager.pojo.sink;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
+import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
+import lombok.NoArgsConstructor;
/**
* Parse field request - with stream
*/
@Data
@Builder
+@NoArgsConstructor
+@AllArgsConstructor
@ApiModel("Parse field request - with stream")
public class ParseFieldRequest {
diff --git a/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java b/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java
index 8015b47a9..ba39c6510 100644
--- a/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java
+++ b/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java
@@ -179,10 +179,8 @@ public class InlongStreamController {
@RequestMapping(value = "/stream/parseFields", method = RequestMethod.POST)
@ApiOperation(value = "Parse inlong stream fields from statement")
- @ApiImplicitParam(name = "parseFieldRequest", dataTypeClass = ParseFieldRequest.class, required = true)
-
- public Response<List<StreamField>> parseFields(@RequestBody ParseFieldRequest request) {
- return Response.success(streamService.parseFields(request));
+ public Response<List<StreamField>> parseFields(@RequestBody ParseFieldRequest parseFieldRequest) {
+ return Response.success(streamService.parseFields(parseFieldRequest));
}
}
diff --git a/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java b/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java
index 59e1a0c9f..8dff84bdd 100644
--- a/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java
+++ b/inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java
@@ -121,7 +121,6 @@ public class StreamSinkController {
@RequestMapping(value = "/sink/parseFields", method = RequestMethod.POST)
@ApiOperation(value = "parse stream sink fields from statement")
- @ApiImplicitParam(name = "parseFieldRequest", dataTypeClass = ParseFieldRequest.class, required = true)
public Response<List<SinkField>> parseFields(@RequestBody ParseFieldRequest parseFieldRequest) {
return Response.success(sinkService.parseFields(parseFieldRequest));
}