This is an automated email from the ASF dual-hosted git repository.
vernedeng pushed a change to branch branch-1.8
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 15d9fd922e [INLONG-8541][Manager] Fix saving InlongGroup with error
tenant (#8542)
new 0540c74316 [INLONG-8543][Docker] Fix mysql connector path error when
docker build (#8544)
new 0e1b97ac83 [INLONG-7763][Sort] Support ddl change for doris (#7764)
new 241ea85e45 [INLONG-8514][Manager] Support ClickHouse field type with
Nullable modifier (#8515)
new 41c9f405db [INLONG-8539][Manager] Logically remove all sources when
agent heartbeat contains no group message (#8540)
new 4e54e74981 [INLONG-8549][Sort] Fix incorrect use of maven plugin on
integration test among sort-end-to-end-tests (#8551)
new 04c153fe36 [INLONG-8556][Manager] Optimize the location of the
manager-plugins-flink jar package (#8557)
new 12fb5689ce [INLONG-8552][Manager] Fix the data preview obtained is not
the latest message (#8553)
new 66006fb1fc [INLONG-8547][Manager] Add workflow approver automatically
when create a new tenant (#8550)
new fa05e0290a [INLONG-8548][Dashboard] Data access supports displaying
transmission delay (#8555)
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docker/build-docker-images.sh | 2 +-
inlong-dashboard/src/ui/locales/cn.json | 4 +
inlong-dashboard/src/ui/locales/en.json | 4 +
.../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 +
.../strategy/ClickHouseFieldTypeStrategy.java | 15 +
.../manager/dao/entity/InlongClusterEntity.java | 1 +
.../manager/dao/entity/InlongClusterTagEntity.java | 1 +
.../dao/mapper/InlongClusterEntityMapper.java | 3 +
.../dao/mapper/InlongClusterTagEntityMapper.java | 2 +
.../dao/mapper/StreamSourceEntityMapper.java | 11 +
.../mappers/InlongClusterEntityMapper.xml | 50 ++-
.../mappers/InlongClusterTagEntityMapper.xml | 26 +-
.../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/sort/util/FieldInfoUtilsTest.java | 2 +-
.../service/heartbeat/HeartbeatServiceImpl.java | 24 +-
.../resource/queue/pulsar/PulsarOperator.java | 15 +-
.../service/tenant/InlongTenantServiceImpl.java | 29 ++
.../service/core/impl/AgentServiceTest.java | 34 +-
.../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/controller/InlongClusterController.java | 23 +-
.../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 +++++++++++
44 files changed, 1547 insertions(+), 151 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%)
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
