diff --git a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/rowdata/InLongMsgUtils.java b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/rowdata/InLongMsgUtils.java index 0dcf7544520..5c39105a5dc 100644 --- a/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/rowdata/InLongMsgUtils.java +++ b/inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/rowdata/InLongMsgUtils.java @@ -20,6 +20,11 @@ import org.apache.inlong.common.pojo.sort.dataflow.field.format.RowFormatInfo; import org.apache.inlong.sort.formats.base.FieldToRowDataConverters; import org.apache.inlong.sort.formats.base.TableFormatUtils; +import org.apache.inlong.sort.formats.inlongmsg.FailureHandler; +import org.apache.inlong.sort.formats.inlongmsg.IgnoreFailureHandler; +import org.apache.inlong.sort.formats.inlongmsg.InLongMsgHead; +import org.apache.inlong.sort.formats.inlongmsg.InLongMsgMetadata; +import org.apache.inlong.sort.formats.inlongmsg.NoOpFailureHandler; import org.apache.flink.api.common.typeinfo.TypeInformation; import org.apache.flink.table.data.GenericRowData; @@ -33,11 +38,6 @@ import org.apache.flink.table.types.logical.RowType; import org.apache.flink.table.types.logical.TimestampType; import org.apache.flink.table.types.logical.VarCharType; -import org.apache.inlong.sort.formats.inlongmsg.IgnoreFailureHandler; -import org.apache.inlong.sort.formats.inlongmsg.InLongMsgHead; -import org.apache.inlong.sort.formats.inlongmsg.InLongMsgMetadata; -import org.apache.inlong.sort.formats.inlongmsg.FailureHandler; -import org.apache.inlong.sort.formats.inlongmsg.NoOpFailureHandler; import javax.annotation.Nullable;