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

["Fabio Lombardelli (JIRA)" <ji...@apache.org>]

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)