[ https://issues.apache.org/jira/browse/SPARK-4294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Tathagata Das reassigned SPARK-4294: ------------------------------------ Assignee: Tathagata Das > The same function should have the same realization. > --------------------------------------------------- > > Key: SPARK-4294 > URL: https://issues.apache.org/jira/browse/SPARK-4294 > Project: Spark > Issue Type: Improvement > Components: Streaming > Affects Versions: 1.1.0 > Reporter: Yadong Qi > Assignee: Tathagata Das > Priority: Minor > Fix For: 1.2.0 > > > In class TransformedDStream: > require(parents.length > 0, "List of DStreams to transform is empty") > require(parents.map(_.ssc).distinct.size == 1, "Some of the DStreams have > different contexts") > require(parents.map(_.slideDuration).distinct.size == 1, > "Some of the DStreams have different slide durations") > In class UnionDStream: > if (parents.length == 0) { > throw new IllegalArgumentException("Empty array of parents") > } > if (parents.map(_.ssc).distinct.size > 1) { > throw new IllegalArgumentException("Array of parents have different > StreamingContexts") > } > if (parents.map(_.slideDuration).distinct.size > 1) { > throw new IllegalArgumentException("Array of parents have different slide > times") > } > The function is the same, but the realization is not. I think they shoule be > the same. -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org