in the select clause unless they are also in the group by clause
or are inside of an aggregate function.
On Jul 18, 2014 5:12 AM, Martin Gammelsæter martingammelsae...@gmail.com
wrote:
Hi again!
I am having problems when using GROUP BY on both SQLContext and
HiveContext (same problem).
My code
)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
java.lang.Thread.run(Thread.java:745)
What am I doing wrong?
--
Best regards,
Martin Gammelsæter
?
I launched the cluster using spark-ec2 from the 1.0.1 release, so I’m
assuming that’s taken care of, at least in theory.
I just spun down the clusters I had up, but I will revisit this tomorrow and
provide the information you requested.
Nick
--
Mvh.
Martin Gammelsæter
92209139
8, 2014 at 8:43 AM, Koert Kuipers ko...@tresata.com wrote:
do you control your cluster and spark deployment? if so, you can try to
rebuild with jetty 9.x
On Tue, Jul 8, 2014 at 9:39 AM, Martin Gammelsæter
martingammelsae...@gmail.com wrote:
Digging a bit more I see that there is yet another
starts up, and
instead manually add the jar to the classpath of every worke), but I
can't seem to find out how)
--
Best regards,
Martin Gammelsæter
on how to solve this? Spark seems to use jetty
8.1.14, while dropwizard uses jetty 9.0.7, so that might be the source
of the problem. Any ideas?
On Tue, Jul 8, 2014 at 2:58 PM, Martin Gammelsæter
martingammelsae...@gmail.com wrote:
Hi!
I am building a web frontend for a Spark app, allowing users
for clarity, is
LocalHiveContext and HiveContext equal if no hive-site.xml is present,
or are there still differences?
--
Best regards,
Martin Gammelsæter
spark driver?
Mohammed
-Original Message-
From: Martin Gammelsæter [mailto:martingammelsae...@gmail.com]
Sent: Friday, July 4, 2014 12:43 AM
To: user@spark.apache.org
Subject: Re: How to use groupByKey and CqlPagingInputFormat
On Thu, Jul 3, 2014 at 10:29 PM, Mohammed Guller moham
= sparkCtx.cassandraTable(ks, cf)
// registerAsTable etc
val res = sql(SELECT id, xmlGetTag(xmlfield, 'sometag') FROM cf)
--
Best regards,
Martin Gammelsæter
to do something like the following:
val casRdd = sparkCtx.cassandraTable(ks, cf)
// registerAsTable etc
val res = sql(SELECT id, xmlGetTag(xmlfield, 'sometag') FROM cf)
--
Best regards,
Martin Gammelsæter
--
Takuya UESHIN
Tokyo, Japan
http://twitter.com/ueshin
--
Mvh.
Martin
a groupByKey in the
above code? I understand that the type does not have that function,
but I'm unclear on what I have to do to make it work.
--
Best regards,
Martin Gammelsæter
-newapihadooprdd-java-equivalent-of-scalas-classof
where I have also asked the same question. Any pointers on how to use
.newAPIHadoopRDD() and CqlPagingInputFormat from Java is greatly
appreciated! (Either here or on Stack Overflow)
--
Best regards,
Martin Gammelsæter
12 matches
Mail list logo