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 2022/03/04 03:35:43 UTC
[incubator-inlong] branch master updated (15f2d59 -> 8843205)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.


    from 15f2d59  [INLONG-2886][Manager] Check if the URL is valid to avoid network security attacks (#2887)
     add 8843205  [INLONG-2856][Manager] Support multi-source and multi-sink in one stream (#2879)

No new revisions were added by this update.

Summary of changes:
 .../inlong/common/pojo/agent/DataConfig.java       |   1 +
 .../inlong/manager/client/api/DataSeparator.java   |   2 +-
 .../manager/client/api/InlongGroupContext.java     |  19 ++-
 .../inlong/manager/client/api/InlongStream.java    |  13 +-
 .../inlong/manager/client/api/StreamSink.java      |   4 +
 .../inlong/manager/client/api/StreamSource.java    |   5 +
 .../api/impl/DefaultInlongStreamBuilder.java       |  72 +++++++---
 .../manager/client/api/impl/InlongGroupImpl.java   |   7 +-
 .../manager/client/api/impl/InlongStreamImpl.java  |  64 +++++++--
 .../client/api/inner/InnerStreamContext.java       |  14 +-
 .../client/api/source/MySQLBinlogSource.java       |  16 ++-
 ...Transfer.java => InlongStreamSinkTransfer.java} | 122 +++++++++--------
 .../api/util/InlongStreamSourceTransfer.java       |  20 ++-
 .../client/api/util/InlongStreamTransfer.java      | 148 ---------------------
 .../common/pojo/sink/SinkBriefResponse.java        |   3 +
 .../manager/common/pojo/sink/SinkForSortDTO.java   |   1 +
 .../manager/common/pojo/sink/SinkListResponse.java |   3 +
 .../manager/common/pojo/sink/SinkRequest.java      |   4 +
 .../manager/common/pojo/sink/SinkResponse.java     |   3 +
 .../common/pojo/source/SourceListResponse.java     |   3 +
 .../manager/common/pojo/source/SourceRequest.java  |   4 +
 .../manager/common/pojo/source/SourceResponse.java |   3 +
 .../common/pojo/source/binlog/BinlogSourceDTO.java |   3 +
 .../source/binlog/BinlogSourceListResponse.java    |   7 +-
 .../pojo/source/binlog/BinlogSourceRequest.java    |  14 +-
 .../pojo/source/binlog/BinlogSourceResponse.java   |   3 +
 .../common/settings/InlongGroupSettings.java       |   2 +-
 .../manager/dao/entity/StreamSinkEntity.java       |   1 +
 .../manager/dao/entity/StreamSourceEntity.java     |   1 +
 .../resources/mappers/StreamSinkEntityMapper.xml   |  55 +++++---
 .../resources/mappers/StreamSourceEntityMapper.xml |  60 ++++++---
 .../service/core/impl/AgentServiceImpl.java        |   2 +-
 .../service/sink/StreamSinkServiceImpl.java        |  45 ++-----
 .../service/source/StreamSourceServiceImpl.java    |  45 +++----
 .../core/sink/ClickHouseStreamSinkServiceTest.java |   2 +
 .../core/sink/HiveStreamSinkServiceTest.java       |   3 +-
 .../core/sink/IcebergStreamSinkServiceTest.java    |   3 +-
 .../core/sink/KafkaStreamSinkServiceTest.java      |   2 +
 .../core/source/StreamSourceServiceTest.java       |   7 +-
 .../source/listener/DataSourceListenerTest.java    |   1 +
 .../thirdparty/sort/DisableZkForSortTest.java      |   2 +
 .../main/resources/sql/apache_inlong_manager.sql   |   8 +-
 .../manager-web/sql/apache_inlong_manager.sql      |   8 +-
 43 files changed, 440 insertions(+), 365 deletions(-)
 copy inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/{InlongStreamTransfer.java => InlongStreamSinkTransfer.java} (68%)