[ 
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15842332#comment-15842332
 ] 

ASF GitHub Bot commented on FLINK-2168:
---------------------------------------

Github user ramkrish86 commented on the issue:

    https://github.com/apache/flink/pull/3149
  
    > Exception: java.lang.OutOfMemoryError thrown from the 
UncaughtExceptionHandler in thread 
"RpcServer.reader=6,bindAddress=testing-docker-bb4f2e37-e79f-42a3-a9e9-4995e42c70ba,port=45919"
    Exception: java.lang.OutOfMemoryError thrown from the 
UncaughtExceptionHandler in thread "CHAIN DataSource (at 
getDataSet(HBaseTableSource.java:63) 
(org.apache.flink.addons.hbase.HBaseTableSourceInputFormat)) -> FlatMap 
(select: (f1.q1 AS q1, f1.q2 AS q2, f1.q3 AS q3)) (6/32)"
    01/27/2017 05:57:12 DataSink (collect())(13/32) switched to DEPLOYING 
    Exception: java.lang.OutOfMemoryError thrown from the 
UncaughtExceptionHandler in thread "LeaseRenewer:travis@localhost:39289"
    01/27/2017 05:57:14 DataSink (collect())(12/32) switched to SCHEDULED 
    Exception: java.lang.OutOfMemoryError thrown from the 
UncaughtExceptionHandler in thread "CHAIN DataSource (at 
getDataSet(HBaseTableSource.java:63) 
(org.apache.flink.addons.hbase.HBaseTableSourceInputFormat)) -> FlatMap 
(select: (f1.q1 AS q1, f1.q2 AS q2, f1.q3 AS q3)) (10/32)"
    
    Getting this error in the travis build. But in my linux box it seems to 
pass.


> Add HBaseTableSource
> --------------------
>
>                 Key: FLINK-2168
>                 URL: https://issues.apache.org/jira/browse/FLINK-2168
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table API & SQL
>    Affects Versions: 0.9
>            Reporter: Fabian Hueske
>            Assignee: ramkrishna.s.vasudevan
>            Priority: Minor
>              Labels: starter
>
> Add a {{HBaseTableSource}} to read data from a HBase table. The 
> {{HBaseTableSource}} should implement the {{ProjectableTableSource}} 
> (FLINK-3848) and {{FilterableTableSource}} (FLINK-3849) interfaces.
> The implementation can be based on Flink's {{TableInputFormat}}.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to