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

PJ Van Aeken commented on FLINK-2055:
-------------------------------------

There appears to be a version mismatch which is why we are not seeing the same 
problems. Turns out my assumptions are not true in version 0.98x but they are 
for the more recent versions 1.x and 2.x (snapshot currently). The inner 
workings of the TableOutputFormat have changed in recent versions, which 
introduces the problem I have described. There is no more auto flush option and 
in stead the TableOutputFormat now uses the BufferedMutator which does the Put 
caching I described earlier. 

> Implement Streaming HBaseSink
> -----------------------------
>
>                 Key: FLINK-2055
>                 URL: https://issues.apache.org/jira/browse/FLINK-2055
>             Project: Flink
>          Issue Type: New Feature
>          Components: Streaming, Streaming Connectors
>    Affects Versions: 0.9
>            Reporter: Robert Metzger
>            Assignee: Hilmi Yildirim
>
> As per : 
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Write-Stream-to-HBase-td1300.html



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

Reply via email to