This is an automated email from the ASF dual-hosted git repository.
yunqing pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from a39e03cc5 [INLONG-8108][Manager] WorkflowApprover API Permissions
Optimization (#8109)
add b9446908f [INLONG-7853][Sort] Add common handle for schema-change in
sink (#8105)
No new revisions were added by this update.
Summary of changes:
.../sort/protocol/enums/SchemaChangePolicy.java | 73 +++++++
.../sort/protocol/enums/SchemaChangeType.java | 94 +++++++++
.../apache/inlong/sort/util/SchemaChangeUtils.java | 229 +++++++++++++++++++++
.../inlong/sort/util/SchemaChangeUtilsTest.java | 62 ++++++
.../org/apache/inlong/sort/base/Constants.java | 13 ++
.../apache/inlong/sort/base/dirty/DirtyType.java | 12 ++
.../sort/base/format/JsonDynamicSchemaFormat.java | 2 +-
.../base/schema/SchemaChangeHandleException.java | 20 +-
8 files changed, 493 insertions(+), 12 deletions(-)
create mode 100644
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/enums/SchemaChangePolicy.java
create mode 100644
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/enums/SchemaChangeType.java
create mode 100644
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/SchemaChangeUtils.java
create mode 100644
inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/util/SchemaChangeUtilsTest.java
copy
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ProxysdkException.java
=>
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/schema/SchemaChangeHandleException.java
(72%)
