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