public void open(Configuration configuration) {
        if (dirtySink != null) {
            try {
                dirtySink.open(configuration);
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
    }
Open for dirty sink

@param configuration The configuration that is used for dirty sink
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/dirty/DirtySinkHelper.java