all

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_04_rosHdfsFromTablev2.scala

@@ -48,7 +48,7 @@ object makedata_04_rosHdfsFromTablev2 {
             "0".equals(not_share)
         }
         .flatMap(record =>{
-          val res = ArrayBuffer((Record, String))
+          val res = ArrayBuffer[(Record, String)]()
           val hour = record.getString("ctx_hour").toInt
           hour match {
             case 23 => res