Re: Exception with hbase

2015-06-05 Thread Hilmi Yildirim
Hi, I fround the reason for that exception. In the TableInputFormat there is the method "configure". This method creates a connection to an hbase table with "this.table = new HTable(hConf, getTableName());". This method is deprecated in the newer versions of hbase-client. You have to use Conn

Exception with hbase

2015-06-05 Thread Hilmi Yildirim
Hi, I am using the SNAPSHOT version of flink to read from hbase and it is working. But we are using a newer version of hbase and if I set the hbase-client dependency to a newer version, then I get the following exception: Caused by: java.util.concurrent.RejectedExecutionException: Task org.a