[
https://issues.apache.org/jira/browse/FLINK-12929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-12929.
------------------------------------
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed on master in
7ea00ad9004f920e0c4c1b6ed906e14418951272
> 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
> Labels: pull-request-available
> Fix For: 1.9.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> 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)
