private List<String> rebuildFieldNameListAndTypeList(List<String> fieldNames, List<String> staticPartitionFields, List<String> fieldTypes, String partitionFields) {
        if (partitionFields == null || partitionFields.isEmpty()) {
            return fieldNames;
        }

        List<String> valueFields = new ArrayList<>(fieldNames);

        for (int i = valueFields.size() - 1; i >= 0; i--) {
            if (staticPartitionFields.contains(fieldNames.get(i))) {
                valueFields.remove(i);
                fieldTypes.remove(i);
            }
        }

        for (int i = 0; i < valueFields.size(); i++) {
            if (partitionFields.contains(fieldNames.get(i))) {
                valueFields.add(valueFields.remove(i));
                fieldTypes.add(fieldTypes.remove(i));
            }
        }

        return valueFields;
    }
execute batch update statement

@throws SQLException throw sql exception
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java