Re: 回复：Spark-submit Problems

2016-10-15 Thread Mekal Zheng
Show me your code 2016年10月16日 +0800 08:24 hxfeng <980548...@qq.com>，写道： > show you pi.py code and what is the exception message? > > > -- 原始邮件 -- > 发件人: "Tobi Bosede";; > 发送时间: 2016年10月16日(星期天) 上午8:04 > 收件人: "user"; > >

Re: scala.MatchError on stand-alone cluster mode

2016-07-17 Thread Mekal Zheng
. -- Mekal Zheng Sent with Airmail 发件人: Rishabh Bhardwaj <rbnex...@gmail.com> <rbnex...@gmail.com> 回复: Rishabh Bhardwaj <rbnex...@gmail.com> <rbnex...@gmail.com> 日期: July 15, 2016 at 17:28:43 至: Saisai Shao <sai.sai.s...@gmail.com> <sai.sai.s...@gmail.com> 抄送

scala.MatchError on stand-alone cluster mode

2016-07-15 Thread Mekal Zheng
uot;, true) val jobConf = hbaseStore.jobConf() aggResults.foreachRDD((rdd, time) => { rdd.map(record => { val logPut = hbaseStore.convert(record, time) (new ImmutableBytesWritable, logPut) }).saveAsHadoopDataset(jobConf) }) } else if (destType == "file") { aggResults.foreachRDD((rdd, time) => { rdd.foreach(record => { val res = record + ("timestamp" -> time.milliseconds) io.File(destPath).appendAll(res.toString() + "\n") }) }) } ssc.start() ssc.awaitTermination() } -- Mekal Zheng Sent with Airmail