This is an automated email from the ASF dual-hosted git repository. healchow pushed a commit to branch release-1.2.0 in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
commit 91344a2e2c99da9a941ef1c98ca319598e4ec56f 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");
