in flink-connector-hbase-1.4/src/main/java/org/apache/flink/connector/hbase1/source/AbstractTableInputFormat.java [206:223]
public void closeTable() {
if (table != null) {
try {
table.close();
} catch (IOException e) {
LOG.warn("Exception occurs while closing HBase Table.", e);
}
table = null;
}
if (connection != null) {
try {
connection.close();
} catch (IOException e) {
LOG.warn("Exception occurs while closing HBase Connection.", e);
}
connection = null;
}
}