You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2023/01/30 02:27:56 UTC
[inlong] branch master updated (afaff30d9 -> 071b0371c)

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

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


    from afaff30d9 [INLONG-7271][Manager] Support comma separation for primary key and partition key of Hudi table (#7272)
     add 071b0371c [INLONG-7278][Manager] Optimize OpenInLongClusterController implementation (#7279)

No new revisions were added by this update.

Summary of changes:
 .../dao/mapper/InlongClusterTagEntityMapper.java   |   2 +-
 .../mappers/InlongClusterTagEntityMapper.xml       |  32 +-
 .../manager/pojo/cluster/BindTagRequest.java       |   2 +-
 .../manager/pojo/cluster/ClusterNodeRequest.java   |  14 +-
 .../manager/pojo/cluster/ClusterRequest.java       |  22 +-
 .../manager/pojo/cluster/ClusterTagRequest.java    |   7 +-
 .../pojo/cluster/agent/AgentClusterDTO.java        |   3 +-
 .../pojo/cluster/es/ElasticsearchClusterDTO.java   |   3 +-
 .../pojo/cluster/kafka/KafkaClusterDTO.java        |   3 +-
 .../pojo/cluster/pulsar/PulsarClusterDTO.java      |   3 +-
 .../pojo/cluster/tubemq/TubeClusterDTO.java        |   3 +-
 .../service/cluster/AbstractClusterOperator.java   |   6 +-
 .../service/cluster/AgentClusterOperator.java      |   6 +-
 .../service/cluster/DataProxyClusterOperator.java  |   2 +-
 .../cluster/ElasticsearchClusterOperator.java      |   3 +-
 .../cluster/InlongClusterOperatorFactory.java      |   2 +-
 .../service/cluster/InlongClusterServiceImpl.java  | 381 +++++++--------------
 .../service/cluster/KafkaClusterOperator.java      |   7 +-
 .../service/cluster/PulsarClusterOperator.java     |   7 +-
 .../service/cluster/TubeClusterOperator.java       |   9 +-
 .../cluster/node/AbstractClusterNodeOperator.java  |  12 +-
 .../cluster/node/AgentClusterNodeOperator.java     |   2 +-
 .../cluster/node/DefaultClusterNodeOperator.java   |   2 +-
 .../manager/common/utils/ValidationUtilsTest.java  |   9 -
 .../service/cluster/InlongClusterServiceTest.java  |  28 +-
 .../web/controller/InlongClusterController.java    |  12 +-
 .../openapi/OpenInLongClusterController.java       |  55 ++-
 27 files changed, 283 insertions(+), 354 deletions(-)