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 <[email protected]>
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");
