This is an automated email from the ASF dual-hosted git repository.
vernedeng pushed a change to branch release-1.8.0
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 15d9fd922e [INLONG-8541][Manager] Fix saving InlongGroup with error
tenant (#8542)
add 0540c74316 [INLONG-8543][Docker] Fix mysql connector path error when
docker build (#8544)
add 0e1b97ac83 [INLONG-7763][Sort] Support ddl change for doris (#7764)
add 241ea85e45 [INLONG-8514][Manager] Support ClickHouse field type with
Nullable modifier (#8515)
add 41c9f405db [INLONG-8539][Manager] Logically remove all sources when
agent heartbeat contains no group message (#8540)
add 4e54e74981 [INLONG-8549][Sort] Fix incorrect use of maven plugin on
integration test among sort-end-to-end-tests (#8551)
add 04c153fe36 [INLONG-8556][Manager] Optimize the location of the
manager-plugins-flink jar package (#8557)
add 12fb5689ce [INLONG-8552][Manager] Fix the data preview obtained is not
the latest message (#8553)
add 66006fb1fc [INLONG-8547][Manager] Add workflow approver automatically
when create a new tenant (#8550)
add fa05e0290a [INLONG-8548][Dashboard] Data access supports displaying
transmission delay (#8555)
add 3da4575c61 [INLONG-8561][Manager] Remove manager-plugin-example.jar
(#8562)
add 0564cd26c0 [INLONG-8570][Manager]Modify packaging order (#8571)
add a08a0b28f2 [INLONG-8576][DataProxy] Adjust handling when messages are
incomplete (#8577)
add f48e05853e [INLONG-8572][Manager] Fix missing information in
InlongStreamBriefInfo (#8573)
add 1d93f8b5a9 [INLONG-8567][Manager] Add new role INLONG_SERVICE for
internal service query (#8568)
add ccf040eba1 [INLONG-8560][Dashboard] Hive supports filling in username
and password (#8569)
add 91368c4b61 [INLONG-8564][Manager] Fix unable to issue tasks when
modifying data node info (#8565)
No new revisions were added by this update.
Summary of changes:
docker/build-docker-images.sh | 2 +-
.../src/plugins/nodes/defaults/Hive.ts | 14 +
inlong-dashboard/src/ui/locales/cn.json | 6 +
inlong-dashboard/src/ui/locales/en.json | 6 +
.../src/ui/pages/GroupDetail/Audit/index.tsx | 2 -
.../pages/GroupDetail/{Audit => Delay}/config.tsx | 42 +-
.../pages/GroupDetail/{Audit => Delay}/index.tsx | 64 ++-
.../src/ui/pages/GroupDetail/index.tsx | 7 +
.../inlong/dataproxy/consts/StatConstants.java | 2 +
.../dataproxy/sink/mq/MessageQueueZoneSink.java | 2 +
.../dataproxy/source/ServerMessageHandler.java | 3 +-
.../strategy/ClickHouseFieldTypeStrategy.java | 15 +
.../manager/dao/entity/InlongClusterEntity.java | 1 +
.../manager/dao/entity/InlongClusterTagEntity.java | 1 +
.../dao/interceptor/MultiTenantInterceptor.java | 50 ++-
.../dao/mapper/InlongClusterEntityMapper.java | 3 +
.../dao/mapper/InlongClusterTagEntityMapper.java | 2 +
.../dao/mapper/StreamSourceEntityMapper.java | 11 +
.../resources/mappers/DataNodeEntityMapper.xml | 68 ++-
.../mappers/InlongClusterEntityMapper.xml | 94 ++--
.../mappers/InlongClusterTagEntityMapper.xml | 53 ++-
.../mappers/InlongConsumeEntityMapper.xml | 92 ++--
.../resources/mappers/InlongGroupEntityMapper.xml | 155 +++++--
.../resources/mappers/StreamSourceEntityMapper.xml | 14 +
.../dao/mapper/InlongClusterEntityMapperTest.java | 23 +
.../base/src/main/assembly/assembly.xml | 2 +
.../manager/pojo/cluster/ClusterPageRequest.java | 3 +
.../manager/pojo/cluster/ClusterRequest.java | 4 +
.../pojo/cluster/ClusterTagPageRequest.java | 3 +
.../manager/pojo/cluster/ClusterTagRequest.java | 4 +
.../manager/pojo/stream/InlongStreamBriefInfo.java | 39 ++
.../inlong/manager/pojo/user/UserRoleCode.java | 5 +
.../manager/pojo/sort/util/FieldInfoUtilsTest.java | 2 +-
inlong-manager/manager-service/pom.xml | 84 ++++
.../service/core/impl/SortSourceServiceImpl.java | 2 +-
.../service/heartbeat/HeartbeatServiceImpl.java | 24 +-
.../service/node/AbstractDataNodeOperator.java | 2 +-
.../manager/service/node/DataNodeOperator.java | 4 +-
.../manager/service/node/DataNodeServiceImpl.java | 56 +--
.../service/node/mysql/MySQLDataNodeOperator.java | 14 +-
.../resource/queue/pulsar/PulsarOperator.java | 15 +-
.../service/tenant/InlongTenantServiceImpl.java | 41 +-
.../service/user/TenantRoleServiceImpl.java | 2 +-
.../manager/service/user/UserServiceImpl.java | 5 +-
.../service/core/impl/AgentServiceTest.java | 34 +-
.../manager/service/sort/SortServiceImplTest.java | 18 +
.../plugins/manager-plugins-base-example.jar | Bin 96655 -> 0 bytes
.../main/resources/h2/apache_inlong_manager.sql | 2 +
inlong-manager/manager-web/assembly.xml | 1 +
.../manager-web/sql/apache_inlong_manager.sql | 5 +-
inlong-manager/manager-web/sql/changes-1.8.0.sql | 14 +-
.../web/auth/tenant/TenantAuthenticatingRealm.java | 8 +-
.../web/controller/InlongClusterController.java | 23 +-
inlong-manager/pom.xml | 2 +-
.../sort/protocol/node/load/DorisLoadNode.java | 42 +-
inlong-sort/sort-end-to-end-tests/pom.xml | 6 +-
.../inlong/sort/base/dirty/DirtyOptions.java | 6 +
.../sort/base/format/JsonDynamicSchemaFormat.java | 2 +
.../sort-flink-v1.13/sort-connectors/doris/pom.xml | 18 +
.../inlong/sort/doris/http/HttpGetEntity.java} | 22 +-
.../inlong/sort/doris/schema/OperationHelper.java | 308 +++++++++++++
.../sort/doris/schema/SchemaChangeHelper.java | 476 +++++++++++++++++++++
.../table/DorisDynamicSchemaOutputFormat.java | 42 +-
.../sort/doris/table/DorisDynamicTableFactory.java | 67 ++-
.../sort/doris/table/DorisDynamicTableSink.java | 17 +-
.../sort/doris/schema/OperationHelperTest.java | 256 +++++++++++
66 files changed, 2098 insertions(+), 314 deletions(-)
copy inlong-dashboard/src/ui/pages/GroupDetail/{Audit => Delay}/config.tsx
(84%)
copy inlong-dashboard/src/ui/pages/GroupDetail/{Audit => Delay}/index.tsx (67%)
delete mode 100644
inlong-manager/manager-service/src/test/resources/plugins/manager-plugins-base-example.jar
copy
inlong-sort/{sort-common/src/test/java/org/apache/inlong/sort/protocol/transformation/operator/EmptyOperatorTest.java
=>
sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/http/HttpGetEntity.java}
(66%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/schema/OperationHelper.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/schema/SchemaChangeHelper.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/test/java/org/apache/inlong/sort/doris/schema/OperationHelperTest.java
