@Override
        public boolean shouldRollOnCheckpoint(PartFileInfo<String> partFileState) {
            return true;
        }
Getting size of the file is too expensive. See {@link HiveBulkWriterFactory#create}. We can't
check for every element, which will cause great pressure on DFS. Therefore, in this
implementation, only check the file size in {@link #shouldRollOnProcessingTime}, which can
effectively avoid DFS pressure.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java