[jira] [Commented] (FLINK-12929) scala.StreamExecutionEnvironment.addSource does not propagate TypeInformation

["Timo Walther (JIRA)" <ji...@apache.org>]

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

Timo Walther commented on FLINK-12929:
--------------------------------------

This makes sense to me. However, we still need to check for the result type queryable interface in this method. Would you like to prepare a fix [~fabio.lombardelli@gmail.com]?

> scala.StreamExecutionEnvironment.addSource does not propagate TypeInformation
> -----------------------------------------------------------------------------
>
>                 Key: FLINK-12929
>                 URL: https://issues.apache.org/jira/browse/FLINK-12929
>             Project: Flink
>          Issue Type: Bug
>          Components: API / Scala, API / Type Serialization System
>            Reporter: Fabio Lombardelli
>            Priority: Critical
>
> In {{scala.StreamExecutionEnvironment.addSource}} I would expect that {{typeInfo}} is also passed to the {{javaEnv.addSource}} as second parameter and not only passed to the {{returns}} method:
> {code:java}
>   def addSource[T: TypeInformation](function: SourceFunction[T]): DataStream[T] = {
>     require(function != null, "Function must not be null.")
>     
>     val cleanFun = scalaClean(function)
>     val typeInfo = implicitly[TypeInformation[T]]
>     asScalaStream(javaEnv.addSource(cleanFun, <missing typeInfo>).returns(typeInfo))
>   }
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)