Minor Description
See code here: https://github.com/apache/spark/blob/master/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala#L894
private[streaming] def rddToFileName[T](prefix: String, suffix: String, time: Time): String = {
if (prefix == null)
else if (suffix == null || suffix.length ==0)
{ prefix + "-" + time.milliseconds }else
{ prefix + "-" + time.milliseconds + "." + suffix }}
This code does not seem to properly handle the cases where the prefix is null, but suffix is not null - the suffix should be used but is not.
Also, the check for length == 0 is only applied to the suffix, bot the prefix. It seems the check should be consistent between the two.
Is there a reason not to address these two issues and change the code?
