[incubator-inlong] branch master updated: [INLONG-4097][Sort] Use javax constrain notNull annotation (#4098)

[healchow]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 4905ddc39 [INLONG-4097][Sort] Use javax constrain notNull annotation 
(#4098)
4905ddc39 is described below

commit 4905ddc39d8433064ceaf3553b2a691640d90f89
Author: Schnapps <zpen...@connect.ust.hk>
AuthorDate: Sat May 7 11:27:10 2022 +0800

    [INLONG-4097][Sort] Use javax constrain notNull annotation (#4098)
---
 .../flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java    | 2 +-
 .../singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java     | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java
 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java
index 4065c814e..6d7f3c248 100644
--- 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java
+++ 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java
@@ -44,6 +44,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import javax.validation.constraints.NotNull;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.table.data.DecimalData;
 import org.apache.flink.table.data.GenericRowData;
@@ -63,7 +64,6 @@ import org.apache.kafka.connect.data.Field;
 import org.apache.kafka.connect.data.Schema;
 import org.apache.kafka.connect.data.Struct;
 import org.apache.kafka.connect.source.SourceRecord;
-import org.jetbrains.annotations.NotNull;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
diff --git 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
index f3cad6383..e19f21dba 100644
--- 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
+++ 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/cdc/mysql/table/MySqlReadableMetadata.java
@@ -23,6 +23,7 @@ import io.debezium.data.Envelope;
 import io.debezium.data.Envelope.FieldName;
 import io.debezium.relational.Table;
 import io.debezium.relational.history.TableChanges;
+import javax.annotation.Nullable;
 import 
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.data.GenericArrayData;
@@ -37,7 +38,6 @@ import 
org.apache.inlong.sort.singletenant.flink.cdc.debezium.table.MetadataConv
 import org.apache.kafka.connect.data.Struct;
 import org.apache.kafka.connect.source.SourceRecord;
 
-import javax.annotation.Nullable;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -114,7 +114,7 @@ public enum MySqlReadableMetadata {
 
             @Override
             public Object read(SourceRecord record,
-                @org.jetbrains.annotations.Nullable TableChanges.TableChange 
tableSchema, RowData rowData) {
+                @Nullable TableChanges.TableChange tableSchema, RowData 
rowData) {
                 // construct canal json
                 Struct messageStruct = (Struct) record.value();
                 Struct sourceStruct = 
messageStruct.getStruct(FieldName.SOURCE);