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

Fabian Hueske commented on FLINK-3988:
--------------------------------------

Hi [~johnlon], I don't think so. The issue is not assigned and hasn't been 
touched since four months.

Would you like to work on it? 

Please note that an implementation needs to interact with Flink's checkpointing 
mechanism in order to provide a certain level of fault-tolerance, i.e., 
at-least once or exactly once semantics. You need a good understanding of how 
checkpointing works and also know about the capabilities and guarantees that 
DistributedLog offers.
We should also check if this is a connector that should go into the Apache 
Flink project or rather into Apache Bahir which is a project that develops 
connectors for distributed data processing systems (AFAIK, Spark and Flink so 
far). The best way to do this is to sent a [DISCUSS] mail to the dev 
mailinglist. 

> Add data set connector to DistributedLog
> ----------------------------------------
>
>                 Key: FLINK-3988
>                 URL: https://issues.apache.org/jira/browse/FLINK-3988
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Jia Zhai
>
> I would like to add a connector to DistributedLog, which recently published 
> by twitter.
> All the infomation of DistributedLog, could be found at here: 
> http://distributedlog.io/html
> And this JIRA ticket is to track the data set connector



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

Reply via email to