flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java [91:103]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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);
        }
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraCommitter.java [115:127]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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);
        }
    }

    @Override
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -