@Override
    public void open(int taskNumber, int numTasks) throws IOException {
        try {
            rowDataMap = new HashMap<>();
            rows = new ArrayList<>();
            metricOutputFormat = this;
            openConnect();
            initScheduledTask(batchWaitInterval);
            init();
            initMetric();
        } catch (Exception e) {
            throw new RuntimeException("impala output format open error!", e);
        }
    }
Date: 2020/10/14
Company: www.dtstack.com

@author tiezhu
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java