Github user fpompermaier commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/172#discussion_r19732836
--- Diff:
flink-addons/flink-hbase/src/main/java/org/apache/flink/addons/hbase/TableInputFormat.java
---
@@ -108,14 +90,16 @@
protected HBaseResult hbaseResult;
- private org.apache.hadoop.conf.Configuration hConf;
+ private Configuration parameters;
+// private org.apache.hadoop.conf.Configuration hConf;
+ public TableInputFormat(Configuration parameters){
+ this.parameters = parameters;
+ }
+
@Override
public void configure(Configuration parameters) {
- HTable table = createTable(parameters);
- setTable(table);
- Scan scan = createScanner(parameters);
- setScan(scan);
+ //TODO why parameters gets empty after execution??
--- End diff --
The problem is that in my TableInputFormat I have to read parameters like
TableInputFormat.INPUT_TABLE and the only way I found to pass them to it is to
pass the to the constructor (i.e. new MyTableInputFormat(conf)).
Indeed, those coming from configure do not contains those parameters..how
can I put TableInputFormat.INPUT_TABLE parameter in those arriving to the TM
through the configure method?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
