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/02/21 08:58:53 UTC

[incubator-inlong] branch master updated (40c5288 -> 2725dbe)

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

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


    from 40c5288  [INLONG-2617][Manager] Change the group status after the new group workflow was executed (#2618)
     add 2725dbe  [INLONG-2616][Manager] Optimize manager client and update service Apis (#2630)

No new revisions were added by this update.

Summary of changes:
 .../inlong/manager/client/api/DataSeparator.java   |   5 +-
 .../manager/client/api/FlinkSortBaseConf.java      |   4 -
 .../apache/inlong/manager/client/api/HiveSink.java |   2 +-
 .../inlong/manager/client/api/InlongGroupConf.java |  11 +-
 .../inlong/manager/client/api/InlongGroupInfo.java |   2 +-
 .../inlong/manager/client/api/InlongStream.java    |   1 -
 .../manager/client/api/InlongStreamBuilder.java    |  15 ++-
 .../manager/client/api/InlongStreamConf.java       |   6 -
 .../inlong/manager/client/api/PulsarBaseConf.java  |   4 -
 .../client/api/auth/DefaultAuthentication.java     |  15 ++-
 .../client/api/auth/SecretAuthentication.java      |  20 ++-
 .../client/api/auth/SecretTokenAuthentication.java |  12 +-
 .../client/api/auth/TokenAuthentication.java       |  16 ++-
 .../api/impl/DefaultInlongStreamBuilder.java       |  59 ++++++++-
 .../manager/client/api/impl/InlongClientImpl.java  |  13 +-
 .../manager/client/api/impl/InlongGroupImpl.java   | 104 ++++++++-------
 .../manager/client/api/impl/InlongStreamImpl.java  |   6 +-
 .../client/api/inner/InnerGroupContext.java        |  16 ++-
 .../client/api/inner/InnerInlongManagerClient.java | 140 +++++++++++++++++++--
 .../inlong/manager/client/api/util/AssertUtil.java |   4 +-
 .../inlong/manager/client/api/util/GsonUtil.java   |  48 ++++---
 .../client/api/util/InlongGroupTransfer.java       |   6 +-
 .../manager/client/api/util/InlongParser.java      |  29 ++++-
 .../client/api/util/InlongStreamTransfer.java      | 113 ++++++++---------
 .../common/pojo/group/InlongGroupPulsarInfo.java   |   5 +
 .../resources/mappers/InlongGroupEntityMapper.xml  |   2 +-
 inlong-manager/manager-plugin-examples/pom.xml     |   2 +-
 .../service/core/impl/InlongGroupServiceImpl.java  |   1 +
 .../manager/service/core/plugin/PluginService.java |  29 ++++-
 .../repository/DataProxyConfigRepository.java      |   3 +
 .../service/core/plugin/PluginClassLoaderTest.java |   1 +
 .../inlong/manager/service/mocks/MockPlugin.java   |   2 +
 .../service/workflow/WorkflowServiceImplTest.java  |   1 +
 .../resources/plugins/manager-plugin-example.jar   | Bin 0 -> 15919 bytes
 .../resources/plugins/manager-plugin-examples.jar  | Bin 12254 -> 0 bytes
 .../main/resources/sql/apache_inlong_manager.sql   |  12 +-
 .../manager-web/sql/apache_inlong_manager.sql      |   2 +-
 .../manager/workflow/definition/WorkflowTask.java  |   3 +-
 38 files changed, 508 insertions(+), 206 deletions(-)
 create mode 100644 inlong-manager/manager-service/src/test/resources/plugins/manager-plugin-example.jar
 delete mode 100644 inlong-manager/manager-service/src/test/resources/plugins/manager-plugin-examples.jar