@Override
    public void open(Configuration configuration) throws Exception {
        converter = FormatJsonUtil.rowDataToJsonConverter(physicalRowDataType);
        fieldGetters = FormatUtils.parseFieldGetters(physicalRowDataType.getLogicalType());
    }
Log dirty sink that is used to print log

@param <T>
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/sink/log/LogDirtySink.java