Fabio Lombardelli created FLINK-12929:
-----------------------------------------
Summary: scala.StreamExecutionEnvironment.addSource does not
propagate TypeInformation
Key: FLINK-12929
URL: https://issues.apache.org/jira/browse/FLINK-12929
Project: Flink
Issue Type: Bug
Reporter: Fabio Lombardelli
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)
