Re: org.apache.spark.sql.AnalysisException: undefined function lit;

2016-02-13 Thread Michael Armbrust
gt; logger.warn("AEDWIP expr: {}", exprStr); > > result.selectExpr("*", exprStr).show(false); > > WARN 02:06:17 streaming-job-executor-0 c.p.f.s.s.CalculateAggregates$1 > call line:96 AEDWIP expr: lit(1455329175000) as ms > > ERROR 02:06:17 JobSchedul

Re: org.apache.spark.sql.AnalysisException: undefined function lit;

2016-02-13 Thread Sebastian Piu
eaming-job-executor-0 c.p.f.s.s.CalculateAggregates$1 > call line:96 AEDWIP expr: lit(1455329175000) as ms > > ERROR 02:06:17 JobScheduler o.a.s.Logging$class logError line:95 Error > running job streaming job 1455329175000 ms.0 > > org.apache.spark.sql.AnalysisException: undefined function lit; > > > >

org.apache.spark.sql.AnalysisException: undefined function lit;

2016-02-12 Thread Andy Davidson
tExpr("*", exprStr).show(false); WARN 02:06:17 streaming-job-executor-0 c.p.f.s.s.CalculateAggregates$1 call line:96 AEDWIP expr: lit(1455329175000) as ms ERROR 02:06:17 JobScheduler o.a.s.Logging$class logError line:95 Error running job streaming job 1455329175000 ms.0 org.apache.spark.s