Re: Where is Flink 0.10.1 documentation?

Hi! I think we missed updating the variable "version" in the "docs/_config.yml" for the 0.10.1 release. Would be good to update it and push a new version of the docs. Greetings, Stephan On Fri, Jan 8, 2016 at 6:51 AM, Chiwan Park wrote: > Hi squirrels, > > I connected

Working with storm compatibility layer

Howdies to everyone, I'm trying to use the storm compatibility layer on Flink 0.10.1. The original storm topology works fine on Storm 0.9.5 and I have incorporated FlinkLocalCluster, FlinkTopologyBuilder, and FlinkTopology classes according to the programming guide

Re: Kinesis Connector

Hi Giancarlo, Since it has been a while since the last post and there hasn't been a JIRA ticket opened for Kinesis connector yet, I'm wondering how you are doing on the Kinesis connector and hope to help out with this feature :) I've opened a JIRA

Re: Where is Flink 0.10.1 documentation?

I updated the version in the "release-0.10" branch, that should fix the issue: http://git-wip-us.apache.org/repos/asf/flink/commit/1d05dbe5 On Fri, Jan 8, 2016 at 10:25 AM, Stephan Ewen wrote: > Hi! > > I think we missed updating the variable "version" in the >

Re: Where is Flink 0.10.1 documentation?

Great, thanks. :) > On Jan 8, 2016, at 6:44 PM, Robert Metzger wrote: > > I updated the version in the "release-0.10" branch, that should fix the > issue: http://git-wip-us.apache.org/repos/asf/flink/commit/1d05dbe5 > > On Fri, Jan 8, 2016 at 10:25 AM, Stephan Ewen

Security in Flink

Hi, Can anyone point me to ant documentation on support for Security in Flink ? The type of information I'm looking for are - 1. How do I do user level authentication to ensure that a job is submitted/deleted/modified by the right user ? Is it possible though the web client ? 2. Authentication

Re: Problem to show logs in task managers

Thanks for the tip Robert! It was a good idea to rule out other possible causes, but I am afraid that is not the problem. If we stick to the WordCountExample (for simplicity), the Exception is thrown if placed into the flatMap function. I am going to try to re-write my problem and all the

Re: Problem to show logs in task managers

You’re right that the log statements of the LineSplitter are in the logs of the cluster nodes, because that’s where the LineSplitter code is executed. In contrast, you create a TestClass on the client when you submit the program. Therefore, you see the logging statement “Logger in TestClass” on