Broadcast variable: error in the wiki?

[stefanobaghino]

Hi all, I'm starting to get familiar with Flink. With the help of a colleague I've noticed what I think may be an error in the documentation about broadcast variables (https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.+Broadcast+Variables).

The documentation states that a broadcast variable "takes a Flink DataSet and makes it available to all function instances". Then it goes on with an example of an anonymous MapFunction invoking the getRuntimeContext method. However, if I got it right, you need to extend a RichMapFunction in order to have access to the runtime context. We've checked the code as well and it looks like getRuntimeContext is only available to classes extending AbstractRichFunction.

I'd like to edit the wiki page myself but unfortunately I don't seem to have writing privileges. Is there a way for me to contribute to the documentation? Thank you in advance.

--

[Stephan Ewen]

Hi!

Thank you for pointing out the error.

I actually fixed it before reading through to the end of your mail where you offered to fix it yourself.

If you find more issues, ping me, I can give you edit permissions.

Thanks,

Stephan

On Tue, Jan 12, 2016 at 11:49 AM, Stefano Baghino <[hidden email]> wrote:

Hi all, I'm starting to get familiar with Flink. With the help of a colleague I've noticed what I think may be an error in the documentation about broadcast variables (https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.+Broadcast+Variables).

The documentation states that a broadcast variable "takes a Flink DataSet and makes it available to all function instances". Then it goes on with an example of an anonymous MapFunction invoking the getRuntimeContext method. However, if I got it right, you need to extend a RichMapFunction in order to have access to the runtime context. We've checked the code as well and it looks like getRuntimeContext is only available to classes extending AbstractRichFunction.

I'd like to edit the wiki page myself but unfortunately I don't seem to have writing privileges. Is there a way for me to contribute to the documentation? Thank you in advance.

--

BR,

Stefano Baghino

Software Engineer @ Radicalbit

[stefanobaghino]

Hi, Stephan, thank you for the quick reply and for fixing the issue. If I spot more issues I'll gladly contribute to the wiki.

On Tue, Jan 12, 2016 at 12:00 PM, Stephan Ewen <[hidden email]> wrote:

Hi!

Thank you for pointing out the error.

I actually fixed it before reading through to the end of your mail where you offered to fix it yourself.

If you find more issues, ping me, I can give you edit permissions.

Thanks,

Stephan

On Tue, Jan 12, 2016 at 11:49 AM, Stefano Baghino <[hidden email]> wrote:

Hi all, I'm starting to get familiar with Flink. With the help of a colleague I've noticed what I think may be an error in the documentation about broadcast variables (https://cwiki.apache.org/confluence/display/FLINK/Variables+Closures+vs.+Broadcast+Variables).

The documentation states that a broadcast variable "takes a Flink DataSet and makes it available to all function instances". Then it goes on with an example of an anonymous MapFunction invoking the getRuntimeContext method. However, if I got it right, you need to extend a RichMapFunction in order to have access to the runtime context. We've checked the code as well and it looks like getRuntimeContext is only available to classes extending AbstractRichFunction.

I'd like to edit the wiki page myself but unfortunately I don't seem to have writing privileges. Is there a way for me to contribute to the documentation? Thank you in advance.

--

BR,

Stefano Baghino

Software Engineer @ Radicalbit

--