[
https://issues.apache.org/jira/browse/FLINK-19064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17189039#comment-17189039
]
Nicholas Jiang edited comment on FLINK-19064 at 9/2/20, 7:24 AM:
-----------------------------------------------------------------
[~rmetzger], DataSourceNode#computeOperatorSpecificDefaultEstimates just call
configure(), doesn't call close(). And in current behavior, open() is called
after createInputSplits() which need use the hbase connection. Therefore, this
is why we can't open the connection in the open() method, and close it in the
close() method.
was (Author: nicholasjiang):
[~rmetzger], DataSourceNode#computeOperatorSpecificDefaultEstimates just call
configure(), doesn't call close(). And in current behavior, open() is called
after createInputSplits which need use the hbase connection. Therefore, this is
why we can't open the connection in the open() method, and close it in the
close() method.
> HBaseRowDataInputFormat is leaking resources
> --------------------------------------------
>
> Key: FLINK-19064
> URL: https://issues.apache.org/jira/browse/FLINK-19064
> Project: Flink
> Issue Type: Bug
> Components: Connectors / HBase
> Affects Versions: 1.12.0
> Reporter: Robert Metzger
> Assignee: Nicholas Jiang
> Priority: Critical
> Labels: pull-request-available
>
> {{HBaseRowDataInputFormat.configure()}} is calling {{connectToTable()}},
> which creates a connection to HBase that is not closed again.
> A user reported this problem on the user@ list:
> https://lists.apache.org/thread.html/ra04f6996eb50ee83aabd2ad0d50bec9afb6a924bfbb48ada3269c6d8%40%3Cuser.flink.apache.org%3E
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
