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

Ismaël Mejía commented on BEAM-2393:
------------------------------------

Actually there is, we implemented this with [[email protected]] but it is in 
the context of Dynamic Work Rebalancing so I am not sure if it will work for 
what you intend, maybe you can look and tell me.
https://github.com/iemejia/beam/blob/BEAM-1531-hbaseio-dwr/sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java#L565
I had not PRed this  yet because the tests are too slow, and I have not had the 
time to improve them, but I expect to do soon.


> BoundedSource is not fault-tolerant in FlinkRunner Streaming mode
> -----------------------------------------------------------------
>
>                 Key: BEAM-2393
>                 URL: https://issues.apache.org/jira/browse/BEAM-2393
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-flink
>            Reporter: Jingsong Lee
>            Assignee: Jingsong Lee
>
> {{BoundedSourceWrapper}} does not implement snapshot() and restore(), when 
> the failure to restart, it will send duplicate data.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to