Re: Apache Flink and serious streaming stateful processing

Hi! You have an interesting use case that I think comes up in many applications (in fact I will be working on something very similar shortly). Stephan has made some nice changes (this PR) to the State interfaces supporting flexible backends, which can b

Re: data sink stops method

Could you post a minimal example of your code where the problem is reproducible? I assume that there has to be another problem because env.execute should actually trigger the execution. Cheers, Till ​ On Thu, Oct 8, 2015 at 8:58 PM, Florian Heyl wrote: > Hey Stephan and Pieter, > That was the

Re: FlinkKafkaConsumer bootstrap.servers vs. broker hosts

Hi, Don't worry – this is quite a low priority question. Definitely not a production issue and as a work around it can be fixed rather easily with suitable network setup. Probably quite rare, too, that this kind of network scenario happens with anyone. But I think that it might be possible to imp