Re: Would like to add a connector to DistributedLog.

Hi Gordon. Thanks a lot for the information and the Jira ticket. On Sun, May 29, 2016 at 1:37 PM, Tzu-Li (Gordon) Tai wrote: > Hi Jia, > > There's currently no dedicated documentation for composing streaming > connectors, but for examples, I would say that the Elasticsearch

Re: Side-effects of DataSet::count

Hey Eron, Yes, DataSet#collect and count methods implicitly trigger a JobGraph execution, thus they also trigger writing to any previously defined sinks. The idea behind this behavior is to enable interactive querying (the one that you are used to get from a shell environment) and it is also a

Side-effects of DataSet::count

I was curious as to how the `count` method on DataSet worked, and was surprised to see that it executes the entire program graph. Wouldn’t this cause undesirable side-effects like writing to sinks?Also strange that the graph is mutated with the addition of a sink (that isn’t subsequently

[jira] [Created] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

Stephan Ewen created FLINK-3990: --- Summary: ZooKeeperLeaderElectionTest kills the JVM Key: FLINK-3990 URL: https://issues.apache.org/jira/browse/FLINK-3990 Project: Flink Issue Type: Bug

Re: GSoC Project Proposal Draft: Code Generation in Serializers

Hi! I would like to give you some status updates on the Google Summer of Code project. I started to implement the proposed features [1]. Status of code generation in general: * I can compile the generated code using Janino compiler * I can load the compiled classes and use them * For some

Re: Would like to add a connector to DistributedLog.

Ah, that's cool. Look forward to your flink connector. we are willing to offer any helps on DL. - Sijie On Sat, May 28, 2016 at 9:33 PM, Jia Zhai wrote: > +Distributedlog groups to get pertential help and instructions. > Thanks. > > On Sun, May 29, 2016 at 11:33 AM, Jia