user
Thread
Date
Earlier messages
Messages by Thread
How to get well-distribute partition
zhaoxw12
apparently non-critical errors running spark-ec2 launch
nicholas.chammas
Re: apparently non-critical errors running spark-ec2 launch
Shivaram Venkataraman
cached rdd in memory eviction
Koert Kuipers
ETL on pyspark
Chengi Liu
Re: ETL on pyspark
Matei Zaharia
Re: ETL on pyspark
Chengi Liu
Re: ETL on pyspark
Chengi Liu
Re: ETL on pyspark
Matei Zaharia
metrics.MetricsSystem: Sink class org.apache.spark.metrics.sink.MetricsServlet cannot be instantialized
Grega Kešpret
Nothing happens when executing on cluster
Anders Bennehag
java.lang.ClassNotFoundException
Terance Dias
Shark server crashes-[Thrift Error]: java.net.SocketException: Socket closed
Arpit Tak
Re: Shark server crashes-[Thrift Error]: java.net.SocketException: Socket closed
Mayur Rustagi
java.io.NotSerializableException
yaoxin
Re: java.io.NotSerializableException
leosand...@gmail.com
Re: java.io.NotSerializableException
yaoxin
Having Spark read a JSON file
nicholas.chammas
Re: Having Spark read a JSON file
Debasish Das
Re: Having Spark read a JSON file
Paul Brown
Disable all spark logging
agg
Re: Disable all spark logging
Shivaram Venkataraman
Re: Disable all spark logging
Nathan Kronenfeld
Re: Disable all spark logging
Guillaume Pitel
GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Re: GraphX with UUID vertex IDs instead of Long
Evan Sparks
Re: GraphX with UUID vertex IDs instead of Long
Josh Rosen
Re: GraphX with UUID vertex IDs instead of Long
Josh Rosen
Re: GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Re: GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Re: GraphX with UUID vertex IDs instead of Long
Ewen Cheslack-Postava
Re: GraphX with UUID vertex IDs instead of Long
Ewen Cheslack-Postava
Re: GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Re: GraphX with UUID vertex IDs instead of Long
Christopher Nguyen
Re: GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Re: GraphX with UUID vertex IDs instead of Long
Christopher Nguyen
Re: GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Re: GraphX with UUID vertex IDs instead of Long
Deepak Nulu
Spark Quick Start - call to open README.md needs explicit fs prefix
nicholas.chammas
Re: Spark Quick Start - call to open README.md needs explicit fs prefix
Matei Zaharia
Re: Spark Quick Start - call to open README.md needs explicit fs prefix
Nicholas Chammas
High CPU usage
Livni, Dana
Re: High CPU usage
Mayur Rustagi
Set memory when using local[k]
agg
Re: Set memory when using local[k]
Gerard Maas
Re: Set memory when using local[k]
agg
Re: Set memory when using local[k]
Aaron Davidson
Spark High Availability
Matan Shukry
Re: Spark High Availability
Aaron Davidson
Re: Spark High Availability
Matan Shukry
Re: Spark High Availability
Aaron Davidson
programmatic way to tell Spark version
nicholas.chammas
Re: programmatic way to tell Spark version
Patrick Wendell
Re: programmatic way to tell Spark version
Nicholas Chammas
standalone spark app build.sbt compilation error
hadoop user
Re: standalone spark app build.sbt compilation error
Tathagata Das
Re: standalone spark app build.sbt compilation error
Spark Storm
How to sort an RDD ?
Fabrizio Milo aka misto
Re: How to sort an RDD ?
Tathagata Das
Re: How to sort an RDD ?
Fabrizio Milo aka misto
Re: How to sort an RDD ?
Tathagata Das
Re: How to sort an RDD ?
Fabrizio Milo aka misto
Re: How to sort an RDD ?
Tathagata Das
Get RDD partition location
Grega Kešpret
Re: Get RDD partition location
Tathagata Das
Trying to connect to spark from within a web server
Nathan Kronenfeld
Re: Trying to connect to spark from within a web server
Mayur Rustagi
Re: Trying to connect to spark from within a web server
Nathan Kronenfeld
Re: Trying to connect to spark from within a web server
Mayur Rustagi
Re: Trying to connect to spark from within a web server
Nathan Kronenfeld
Re: Trying to connect to spark from within a web server
Soumya Simanta
Spark-AMI version compatibility table
nicholas.chammas
Re: Spark-AMI version compatibility table
Nicholas Chammas
spark compile time error: jarOfClass
Ankur Saran
Re: spark compile time error: jarOfClass
Tathagata Das
UseCompressedStrings
Fabrizio Milo aka misto
Re: UseCompressedStrings
Shivaram Venkataraman
unable to deploy spark cluster with docker script
Jaonary Rabarisoa
Spark Summit 2014
Scott walent
OOM when calling cache on RDD with big data
tdeng
OOM when calling cache on RDD with big data
Tianshuo Deng
log4j on pyspark
Diana Carroll
spark/shark + cql3
Liam Stewart
Re: spark/shark + cql3
Heiko Braun
Re: spark/shark + cql3
Liam Stewart
Re: spark/shark + cql3
Heiko Braun
Re: spark/shark + cql3
Heiko Braun
Re: spark/shark + cql3
Rohit Rai
Re: spark/shark + cql3
Azuryy Yu
Creating a Spark context from a Scalatra servlet
Ognen Duzlevski
Re: Creating a Spark context from a Scalatra servlet
Ognen Duzlevski
Re: Creating a Spark context from a Scalatra servlet
Nick Pentreath
Re: Creating a Spark context from a Scalatra servlet
Ognen Duzlevski
Re: Creating a Spark context from a Scalatra servlet
Nick Pentreath
Re: Creating a Spark context from a Scalatra servlet
Ognen Duzlevski
Re: Creating a Spark context from a Scalatra servlet
Ognen Duzlevski
Re: Creating a Spark context from a Scalatra servlet
Ognen Duzlevski
Spark HDFS read/write in local mode and cluster mode behaviour
Jaggu
Using PySpark for Streaming
Prasanth Prahladan
Re: Using PySpark for Streaming
Jeremy Freeman
Re: Using PySpark for Streaming
D.Y Feng
Re: Using PySpark for Streaming
Tathagata Das
[incubating-0.9.0] Too Many Open Files on Workers
andy petrella
Re: [incubating-0.9.0] Too Many Open Files on Workers
Sourav Chandra
Re: [incubating-0.9.0] Too Many Open Files on Workers
andy petrella
Can spark-streaming work with spark-on-yarn mode?
林武康
Re: Can spark-streaming work with spark-on-yarn mode?
Tathagata Das
Re: SparkContext startup time out
yaoxin
Re: SparkContext startup time out
Mayur Rustagi
Custom RDD gets HadoopSplit for compute() call
Dmitriy Lyubimov
Re: Custom RDD gets HadoopSplit for compute() call
Dmitriy Lyubimov
Re: Custom RDD gets HadoopSplit for compute() call
Dmitriy Lyubimov
multi-concurrent proccessing
Livni, Dana
Re: multi-concurrent proccessing
Mayur Rustagi
multi-concurrent proccessing
Livni, Dana
file not found
Mohit Singh
Re: file not found
Bryn Keller
Re: file not found
Mohit Singh
Running spark on cluster
Mohit Singh
Re: Running spark on cluster
Mayur Rustagi
Re: Running spark on cluster
Mohit Singh
Re: Running spark on cluster
Mayur Rustagi
Re: Running spark on cluster
Mohit Singh
Re: Running spark on cluster
Mayur Rustagi
How to build spark-0.9.0 on a proxied system
9000revs
Re: How to build spark-0.9.0 on a proxied system
Jey Kottalam
Explain About Logs NetworkWordcount.scala
Eduardo Costa Alfaia
Re: Explain About Logs NetworkWordcount.scala
Mayur Rustagi
Re: Explain About Logs NetworkWordcount.scala
Tathagata Das
saving RDD to disk - fault tolerance
Adrian Mocanu
Re: saving RDD to disk - fault tolerance
Mayur Rustagi
accumulator duration
Adrian Mocanu
How to submit a job to Spark cluster?
Tao Xiao
Re: How to submit a job to Spark cluster?
Nan Zhu
Re: How to submit a job to Spark cluster?
Mayur Rustagi
Re: How to submit a job to Spark cluster?
Tao Xiao
Re: How to submit a job to Spark cluster?
Nan Zhu
Re: How to submit a job to Spark cluster?
Mayur Rustagi
Re: How to submit a job to Spark cluster?
Tao Xiao
Tachyon RDD Caching
arosenberger
Fair Scheduling
vinay Bajaj
How I can run the sbt command on the server
lihu
Re: How I can run the sbt command on the server
lihu
Re: How I can run the sbt command on the server
Mayur Rustagi
Re: How I can run the sbt command on the server
lihu
Unable to read HDFS file -- SimpleApp.java
Prasad
Re: Unable to read HDFS file -- SimpleApp.java
vinay Bajaj
Re: Unable to read HDFS file -- SimpleApp.java
Prasad
Master UI does not show any driver information
Sourav Chandra
Basic question on RDD caching
David Thomas
Re: Basic question on RDD caching
Ewen Cheslack-Postava
Re: Basic question on RDD caching
David Thomas
Re: Basic question on RDD caching
Ewen Cheslack-Postava
How to achieve this in Spark
Soumya Simanta
Re: How to achieve this in Spark
Mark Hamstra
Re: How to achieve this in Spark
Nathan Kronenfeld
Re: How to achieve this in Spark
Mayur Rustagi
Q: Discretized Streams: Fault-Tolerant Streaming Computation paper
Adrian Mocanu
Re: Q: Discretized Streams: Fault-Tolerant Streaming Computation paper
dachuan
RE: Q: Discretized Streams: Fault-Tolerant Streaming Computation paper
Adrian Mocanu
Re: Q: Discretized Streams: Fault-Tolerant Streaming Computation paper
Tathagata Das
Why collect() has a stage but first() not?
David Thomas
Re: Why collect() has a stage but first() not?
Aaron Davidson
Re: Why collect() has a stage but first() not?
David Thomas
Re: Why collect() has a stage but first() not?
Aaron Davidson
Re: Why collect() has a stage but first() not?
David Thomas
Re: Why collect() has a stage but first() not?
Mark Hamstra
Execution blocked when collect()ing some relatively big blocks on spark 0.9
Guillaume Pitel
Re: Execution blocked when collect()ing some relatively big blocks on spark 0.9
Guillaume Pitel
Re: Execution blocked when collect()ing some relatively big blocks on spark 0.9
Roshan Nair
Re: Execution blocked when collect()ing some relatively big blocks on spark 0.9
Guillaume Pitel
Re: Execution blocked when collect()ing some relatively big blocks on spark 0.9
Guillaume Pitel
Re: Execution blocked when collect()ing some relatively big blocks on spark 0.9
Roshan Nair
Building Spark reports "Could not create directory /usr/local/ims/spark/spark-0.9.0-incubating-bin-hadoop1/assembly/target/streams/compile/$global/$global"
Tao Xiao
Re: Building Spark reports "Could not create directory /usr/local/ims/spark/spark-0.9.0-incubating-bin-hadoop1/assembly/target/streams/compile/$global/$global"
Nan Zhu
Re: Building Spark reports "Could not create directory /usr/local/ims/spark/spark-0.9.0-incubating-bin-hadoop1/assembly/target/streams/compile/$global/$global"
Tao Xiao
How is a spark node crash handled by spark wrt running DStream
Adrian Mocanu
ReduceByKey or groupByKey to Count?
dmpour23
Re: ReduceByKey or groupByKey to Count?
Mayur Rustagi
how can I make the sliding window in Spark Streaming driven by data timestamp instead of absolute time
Aries Kong
Spark process locality
vinay Bajaj
Re: Spark process locality
Mayur Rustagi
Re: Spark process locality
Patrick Wendell
Re: Spark process locality
vinay Bajaj
Re: Spark process locality
Mayur Rustagi
Re: Spark process locality
vinay Bajaj
Re: Spark process locality
Mayur Rustagi
Re: Spark process locality
dachuan
Re: Spark process locality
Mayur Rustagi
Spark 0.9.0
Gino Mathews
Re: Spark 0.9.0
Mayur Rustagi
OutOfMemory Error
zhaoxw12
Re: OutOfMemory Error
Mayur Rustagi
Re: OutOfMemory Error
zhaoxw12
How to compile Spark applications using sbt?
Tao Xiao
Re: How to compile Spark applications using sbt?
dachuan
Re: How to compile Spark applications using sbt?
Mayur Rustagi
Re: How to compile Spark applications using sbt?
Tao Xiao
Re: How to compile Spark applications using sbt?
dachuan
Spark Streaming windowing Driven by absolutely time?
Aries Kong
Earlier messages