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 10:32:58 GMT

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

ASF GitHub Bot commented on FLINK-4883:

Github user aljoscha commented on the issue:

    it should just be a warning in the Javadoc/Scaladoc, probably in bold. That's what I meant.

> 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