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 to
> https://ci.apache.o
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
> "docs/_config.yml" for the 0.10.1
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 wrote:
> Hi!
>
> I think w
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 a
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 setti
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
the
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
(https://ci.apache.org/projects/
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 (https://issues.apache.org/jira/browse/FLINK-3211
