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
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/
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
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
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
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
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
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