public void close()

in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReader.java [165:180]

• 16 lines of code
• 5 McCabe index (conditional complexity)

    public void close() throws IOException {
        try {
            if (session != null) {
                session.close();
            }
        } catch (KuduException e) {
            log.error("Error while closing session.", e);
        }
        try {
            if (client != null) {
                client.close();
            }
        } catch (Exception e) {
            log.error("Error while closing client.", e);
        }
    }