You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by he...@apache.org on 2022/06/09 02:20:37 UTC
[incubator-inlong] branch master updated: [INLONG-4601][Manager] Change the fieldList in SinkRequest to sinkFieldList (#4604)
This is an automated email from the ASF dual-hosted git repository.
healchow 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 3d5933141 [INLONG-4601][Manager] Change the fieldList in SinkRequest to sinkFieldList (#4604)
3d5933141 is described below
commit 3d593314124def8898d075a8f02572503f227ae7
Author: jiancheng Lv <63...@qq.com>
AuthorDate: Thu Jun 9 10:20:32 2022 +0800
[INLONG-4601][Manager] Change the fieldList in SinkRequest to sinkFieldList (#4604)
---
.../org/apache/inlong/manager/common/pojo/sink/SinkRequest.java | 2 +-
.../apache/inlong/manager/service/sink/StreamSinkServiceImpl.java | 4 ++--
.../inlong/manager/service/sink/ck/ClickHouseSinkOperation.java | 4 ++--
.../manager/service/sink/es/ElasticsearchSinkOperation.java | 4 ++--
.../manager/service/sink/greenplum/GreenplumSinkOperation.java | 4 ++--
.../inlong/manager/service/sink/hbase/HBaseSinkOperation.java | 4 ++--
.../inlong/manager/service/sink/hdfs/HdfsSinkOperation.java | 4 ++--
.../inlong/manager/service/sink/hive/HiveSinkOperation.java | 8 ++++----
.../inlong/manager/service/sink/iceberg/IcebergSinkOperation.java | 4 ++--
.../inlong/manager/service/sink/kafka/KafkaSinkOperation.java | 4 ++--
.../inlong/manager/service/sink/mysql/MySQLSinkOperation.java | 4 ++--
.../manager/service/sink/postgres/PostgresSinkOperation.java | 4 ++--
.../manager/service/sink/sqlserver/SqlServerSinkOperation.java | 4 ++--
.../manager/service/core/sink/GreenplumStreamSinkServiceTest.java | 2 +-
.../manager/service/core/sink/HdfsStreamSinkServiceTest.java | 2 +-
.../manager/service/core/sink/MysqlStreamSinkServiceTest.java | 2 +-
.../apache/inlong/manager/service/sort/DisableZkForSortTest.java | 2 +-
17 files changed, 31 insertions(+), 31 deletions(-)
diff --git a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/SinkRequest.java b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/SinkRequest.java
index 7f1471aad..e532e586c 100644
--- a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/SinkRequest.java
+++ b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/SinkRequest.java
@@ -74,7 +74,7 @@ public class SinkRequest {
private Integer enableCreateResource = 1;
@ApiModelProperty("Sink field list")
- private List<SinkField> fieldList;
+ private List<SinkField> sinkFieldList;
@ApiModelProperty("Other properties if needed")
private Map<String, Object> properties = Maps.newHashMap();
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
index 29097b0be..335435653 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java
@@ -101,7 +101,7 @@ public class StreamSinkServiceImpl implements StreamSinkService {
// According to the sink type, save sink information
StreamSinkOperation operation = operationFactory.getInstance(SinkType.forType(sinkType));
- List<SinkField> fields = request.getFieldList();
+ List<SinkField> fields = request.getSinkFieldList();
// Remove id in sinkField when save
if (CollectionUtils.isNotEmpty(fields)) {
fields.stream().forEach(sinkField -> sinkField.setId(null));
@@ -208,7 +208,7 @@ public class StreamSinkServiceImpl implements StreamSinkService {
throw new BusinessException(String.format(err, sinkName, groupId, streamId));
}
}
- List<SinkField> fields = request.getFieldList();
+ List<SinkField> fields = request.getSinkFieldList();
// Remove id in sinkField when save
if (CollectionUtils.isNotEmpty(fields)) {
fields.stream().forEach(sinkField -> sinkField.setId(null));
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java
index 9824a47ea..4fdddf1b3 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperation.java
@@ -107,7 +107,7 @@ public class ClickHouseSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -210,7 +210,7 @@ public class ClickHouseSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java
index aa1c612ee..271148c08 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperation.java
@@ -107,7 +107,7 @@ public class ElasticsearchSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -210,7 +210,7 @@ public class ElasticsearchSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java
index 2e57797df..2ce71bdca 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/greenplum/GreenplumSinkOperation.java
@@ -105,7 +105,7 @@ public class GreenplumSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -204,7 +204,7 @@ public class GreenplumSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java
index b82a12bbb..83e34b2dc 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hbase/HBaseSinkOperation.java
@@ -104,7 +104,7 @@ public class HBaseSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save hbase field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -206,7 +206,7 @@ public class HBaseSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java
index 7da67db57..2f4ccac58 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hdfs/HdfsSinkOperation.java
@@ -105,7 +105,7 @@ public class HdfsSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save hdfs field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -204,7 +204,7 @@ public class HdfsSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java
index c345a3013..dc82e9f55 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/hive/HiveSinkOperation.java
@@ -80,7 +80,7 @@ public class HiveSinkOperation implements StreamSinkOperation {
Preconditions.checkTrue(SinkType.SINK_HIVE.equals(sinkType),
ErrorCodeEnum.SINK_TYPE_NOT_SUPPORT.getMessage() + ": " + sinkType);
HiveSinkRequest hiveRequest = (HiveSinkRequest) request;
- LoadNodeUtils.checkPartitionField(hiveRequest.getFieldList(), hiveRequest.getPartitionFieldList());
+ LoadNodeUtils.checkPartitionField(hiveRequest.getSinkFieldList(), hiveRequest.getPartitionFieldList());
StreamSinkEntity entity = CommonBeanUtils.copyProperties(hiveRequest, StreamSinkEntity::new);
entity.setStatus(SinkStatus.NEW.getCode());
entity.setIsDeleted(GlobalConstants.UN_DELETED);
@@ -107,7 +107,7 @@ public class HiveSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save hive field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -187,7 +187,7 @@ public class HiveSinkOperation implements StreamSinkOperation {
StreamSinkEntity entity = sinkMapper.selectByPrimaryKey(request.getId());
Preconditions.checkNotNull(entity, ErrorCodeEnum.SINK_INFO_NOT_FOUND.getMessage());
HiveSinkRequest hiveRequest = (HiveSinkRequest) request;
- LoadNodeUtils.checkPartitionField(hiveRequest.getFieldList(), hiveRequest.getPartitionFieldList());
+ LoadNodeUtils.checkPartitionField(hiveRequest.getSinkFieldList(), hiveRequest.getPartitionFieldList());
CommonBeanUtils.copyProperties(hiveRequest, entity, true);
try {
HiveSinkDTO dto = HiveSinkDTO.getFromRequest(hiveRequest);
@@ -211,7 +211,7 @@ public class HiveSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java
index e1c1a6764..317af3a0c 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/iceberg/IcebergSinkOperation.java
@@ -106,7 +106,7 @@ public class IcebergSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save iceberg field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -230,7 +230,7 @@ public class IcebergSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java
index 33fec7b74..ffd31b34f 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/kafka/KafkaSinkOperation.java
@@ -105,7 +105,7 @@ public class KafkaSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -204,7 +204,7 @@ public class KafkaSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java
index ae43289c3..b8d017e8b 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/mysql/MySQLSinkOperation.java
@@ -105,7 +105,7 @@ public class MySQLSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -204,7 +204,7 @@ public class MySQLSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java
index dbb59ff85..186009925 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/postgres/PostgresSinkOperation.java
@@ -104,7 +104,7 @@ public class PostgresSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -203,7 +203,7 @@ public class PostgresSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java
index 23d2b823a..8169de58d 100644
--- a/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java
+++ b/inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/sqlserver/SqlServerSinkOperation.java
@@ -105,7 +105,7 @@ public class SqlServerSinkOperation implements StreamSinkOperation {
@Override
public void saveFieldOpt(SinkRequest request) {
- List<SinkField> fieldList = request.getFieldList();
+ List<SinkField> fieldList = request.getSinkFieldList();
LOGGER.info("begin to save field={}", fieldList);
if (CollectionUtils.isEmpty(fieldList)) {
return;
@@ -204,7 +204,7 @@ public class SqlServerSinkOperation implements StreamSinkOperation {
@Override
public void updateFieldOpt(Boolean onlyAdd, SinkRequest request) {
Integer sinkId = request.getId();
- List<SinkField> fieldRequestList = request.getFieldList();
+ List<SinkField> fieldRequestList = request.getSinkFieldList();
if (CollectionUtils.isEmpty(fieldRequestList)) {
return;
}
diff --git a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/GreenplumStreamSinkServiceTest.java b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/GreenplumStreamSinkServiceTest.java
index ec61cca0f..9cd11939d 100644
--- a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/GreenplumStreamSinkServiceTest.java
+++ b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/GreenplumStreamSinkServiceTest.java
@@ -75,7 +75,7 @@ public class GreenplumStreamSinkServiceTest extends ServiceBaseTest {
sinkField.setId(fieldId);
List<SinkField> sinkFieldList = new ArrayList<>();
sinkFieldList.add(sinkField);
- sinkInfo.setFieldList(sinkFieldList);
+ sinkInfo.setSinkFieldList(sinkFieldList);
return sinkService.save(sinkInfo, globalOperator);
}
diff --git a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/HdfsStreamSinkServiceTest.java b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/HdfsStreamSinkServiceTest.java
index 26413ea0f..aefa597b8 100644
--- a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/HdfsStreamSinkServiceTest.java
+++ b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/HdfsStreamSinkServiceTest.java
@@ -72,7 +72,7 @@ public class HdfsStreamSinkServiceTest extends ServiceBaseTest {
sinkField.setId(fieldId);
List<SinkField> sinkFieldList = new ArrayList<>();
sinkFieldList.add(sinkField);
- hdfsSinkRequest.setFieldList(sinkFieldList);
+ hdfsSinkRequest.setSinkFieldList(sinkFieldList);
return sinkService.save(hdfsSinkRequest, globalOperator);
}
diff --git a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/MysqlStreamSinkServiceTest.java b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/MysqlStreamSinkServiceTest.java
index cee696395..d41359242 100644
--- a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/MysqlStreamSinkServiceTest.java
+++ b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/core/sink/MysqlStreamSinkServiceTest.java
@@ -75,7 +75,7 @@ public class MysqlStreamSinkServiceTest extends ServiceBaseTest {
sinkField.setId(fieldId);
List<SinkField> sinkFieldList = new ArrayList<>();
sinkFieldList.add(sinkField);
- sinkInfo.setFieldList(sinkFieldList);
+ sinkInfo.setSinkFieldList(sinkFieldList);
return sinkService.save(sinkInfo, globalOperator);
}
diff --git a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/DisableZkForSortTest.java b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/DisableZkForSortTest.java
index 70e809e10..2dd1eb32d 100644
--- a/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/DisableZkForSortTest.java
+++ b/inlong-manager/manager-service/src/test/java/org/apache/inlong/manager/service/sort/DisableZkForSortTest.java
@@ -90,7 +90,7 @@ public class DisableZkForSortTest extends WorkflowServiceImplTest {
return fieldInfo;
})
.collect(Collectors.toList());
- sinkRequest.setFieldList(sinkFields);
+ sinkRequest.setSinkFieldList(sinkFields);
sinkRequest.setEnableCreateResource(0);
sinkRequest.setUsername(OPERATOR);
sinkRequest.setPassword("password");