Andrea Sella created FLINK-5877:
---
Summary: Fix Scala snippet in Async I/O API doc
Key: FLINK-5877
URL: https://issues.apache.org/jira/browse/FLINK-5877
Project: Flink
Issue Type: Improvement
Andrea Sella created FLINK-4119:
---
Summary: Null checks in close() for Cassandra Input/Output
Formats, checking arguments via Flink Preconditions
Key: FLINK-4119
URL: https://issues.apache.org/jira/browse/FLINK-4119
Hi Robert,
Yes, it works in the current master. Thank you.
Cheers,
Andrea
2016-06-16 14:03 GMT+02:00 Robert Metzger :
> @Andrea: Do I understand correctly that the scala-shell works with HA in
> the current master? If so, it will be included automatically into the
> release.
>
> I created a Wik
Hi Robert,
Another interesting features to add in 1.1.0 should be the scala-shell
integration with YARN in HA[1].
Thank you,
Andrea
[1]
http://mail-archives.apache.org/mod_mbox/flink-dev/201604.mbox/%3CCABsXpV1Qu7v8cwxx-DkQ4JRNBvGNh-EF2MxdjzyYjsWUpQn01g%40mail.gmail.com%3E
2016-06-15 22:50 GMT+
t mistaken, then
>> flink-conf.yaml is read too late and is, thus, not respected. I’ll
>> verify it and if valid, then I’ll open another issue and fix it.
>>
>> Thanks for your patience and thorough reporting. It helps a lot :-)
>>
>> Cheers,
>> Till
>>
in the flink-conf.yaml file. You then give the FlinkILoop the
> conf object.
>
> I’m not sure whether you can specify a custom flink configuration in
> Zeppelin. I think you can only specify a host and port. So either you start
> you Flink cluster in non-HA mode or you have to pat
Hi,
I am working to allow Zeppelin's flink interpreter to connect an existing
yarn cluster. Yarn cluster has started via yarn-session and flink's version
is 1.0.0.
My approach is to read host and port from .yarn-properties and pass them to
IFlinkLoop.
Now I am facing an issue with Session ID when
+1 for moving to external classes, it is much simpler to analyze/study few
little blocks of code than one bigger imho.
Andrea
2016-01-22 9:41 GMT+01:00 Aljoscha Krettek :
> Hi,
> the changes to the KMeans example look good so far. About moving
> everything to external classes, IMHO we should do
