public void close()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java [113:125]

• 13 lines of code
• 3 McCabe index (conditional complexity)

    public void close() throws Exception {
        this.lastCommittedCheckpoints.clear();
        try {
            session.close();
        } catch (Exception e) {
            LOG.error("Error while closing session.", e);
        }
        try {
            cluster.close();
        } catch (Exception e) {
            LOG.error("Error while closing cluster.", e);
        }
    }