flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects
Date Thu, 15 Dec 2016 01:45:59 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15750067#comment-15750067

ASF GitHub Bot commented on FLINK-4883:

Github user Renkai commented on the issue:

    Hi, @aljoscha I'm wondering about how could the warning be "big", should it have a different
color in the console or pop out an alert window when people submit apps from web?

> Prevent UDFs implementations through Scala singleton objects
> ------------------------------------------------------------
>                 Key: FLINK-4883
>                 URL: https://issues.apache.org/jira/browse/FLINK-4883
>             Project: Flink
>          Issue Type: Bug
>            Reporter: Stefan Richter
>            Assignee: Renkai Ge
> Currently, user can create and use UDFs in Scala like this:
> {code}
> object FlatMapper extends RichCoFlatMapFunction[Long, String, (Long, String)] {
> ...
> }
> {code}
> However, this leads to problems as the UDF is now a singleton that Flink could use across
several operator instances, which leads to job failures. We should detect and prevent the
usage of singleton UDFs.

This message was sent by Atlassian JIRA

View raw message