[
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)
