Repository: spark
Updated Branches:
refs/heads/branch-1.0 fdf9717da -> 9f0f2ecb8
default task number misleading in several places
private[streaming] def defaultPartitioner(numPartitions: Int =
self.ssc.sc.defaultParallelism){
new HashPartitioner(numPartitions)
}
it represents that th
Repository: spark
Updated Branches:
refs/heads/master 44165fc91 -> 2f639957f
default task number misleading in several places
private[streaming] def defaultPartitioner(numPartitions: Int =
self.ssc.sc.defaultParallelism){
new HashPartitioner(numPartitions)
}
it represents that the de
