| Ashutosh Joshi |
[Structured Streaming] Domain data refresh with flatMapGroupsWithState |
Sat, 01 Feb, 03:19 |
| Jungtaek Lim |
Re: Extract value from streaming Dataframe to a variable |
Mon, 03 Feb, 02:21 |
| Jungtaek Lim |
Re: How to prevent and track data loss/dropped due to watermark during structure streaming aggregation |
Mon, 03 Feb, 03:06 |
| Ruijing Li |
Best way to read batch from Kafka and Offsets |
Mon, 03 Feb, 08:38 |
| Chris Teoh |
Re: Best way to read batch from Kafka and Offsets |
Mon, 03 Feb, 09:36 |
| Ruijing Li |
Re: Best way to read batch from Kafka and Offsets |
Mon, 03 Feb, 19:13 |
| Chris Teoh |
Re: Best way to read batch from Kafka and Offsets |
Mon, 03 Feb, 21:50 |
| Anil Kulkarni |
Re: Best way to read batch from Kafka and Offsets |
Mon, 03 Feb, 23:14 |
| asma zgolli |
shuffle mathematic formulat |
Tue, 04 Feb, 11:57 |
| Aironman DirtDiver |
Re: shuffle mathematic formulat |
Tue, 04 Feb, 12:10 |
| edge7 |
Committer to use if "spark.sql.sources.partitionOverwriteMode": 'dynamic' |
Tue, 04 Feb, 16:39 |
| Burak Yavuz |
Re: Best way to read batch from Kafka and Offsets |
Wed, 05 Feb, 00:20 |
| Karthik Srinivas |
Data locality |
Wed, 05 Feb, 00:33 |
| Ruijing Li |
Re: Best way to read batch from Kafka and Offsets |
Wed, 05 Feb, 00:41 |
| Burak Yavuz |
Re: Best way to read batch from Kafka and Offsets |
Wed, 05 Feb, 00:59 |
| Karthik Srinivas |
[ spark-streaming ] - Data Locality issue |
Wed, 05 Feb, 04:59 |
| Gourav Sengupta |
Re: Best way to read batch from Kafka and Offsets |
Wed, 05 Feb, 08:48 |
| Zhang Victor |
SparkAppHandle can not stop application in yarn client mode |
Wed, 05 Feb, 09:02 |
| Cool Joe |
subscribe |
Thu, 06 Feb, 01:35 |
| Ruijing Li |
Re: Best way to read batch from Kafka and Offsets |
Thu, 06 Feb, 02:13 |
| Ruijing Li |
Re: Best way to read batch from Kafka and Offsets |
Thu, 06 Feb, 03:07 |
| Marcelo Valle |
dataframe null safe joins given a list of columns |
Thu, 06 Feb, 12:45 |
| stevech.hu |
Re: How to prevent and track data loss/dropped due to watermark during structure streaming aggregation |
Fri, 07 Feb, 09:05 |
| Vijayant Kumar |
Spark Application Dynamic IP and Path assign. |
Fri, 07 Feb, 11:06 |
| Dongjoon Hyun |
[ANNOUNCE] Announcing Apache Spark 2.4.5 |
Sun, 09 Feb, 01:22 |
| Dongjoon Hyun |
Re: [ANNOUNCE] Announcing Apache Spark 2.4.5 |
Sun, 09 Feb, 01:27 |
| Takeshi Yamamuro |
Re: [ANNOUNCE] Announcing Apache Spark 2.4.5 |
Sun, 09 Feb, 01:49 |
| Hyukjin Kwon |
Re: [ANNOUNCE] Announcing Apache Spark 2.4.5 |
Mon, 10 Feb, 08:17 |
| Wenchen Fan |
Re: [ANNOUNCE] Announcing Apache Spark 2.4.5 |
Tue, 11 Feb, 03:39 |
| Jungtaek Lim |
Re: [ANNOUNCE] Announcing Apache Spark 2.4.5 |
Tue, 11 Feb, 03:43 |
| Nicolas PARIS |
Ceph / Lustre VS hdfs comparison |
Wed, 12 Feb, 13:31 |
| Ashley Hoff |
Questions about count() performance with dataframes and parquet files |
Thu, 13 Feb, 04:08 |
| WranglingData |
Re: Start a standalone server as root and use it with user accounts |
Thu, 13 Feb, 04:51 |
| David Edwards |
Re: Questions about count() performance with dataframes and parquet files |
Thu, 13 Feb, 05:45 |
| Ashley Hoff |
Re: Questions about count() performance with dataframes and parquet files |
Thu, 13 Feb, 06:08 |
| David Edwards |
Re: Questions about count() performance with dataframes and parquet files |
Thu, 13 Feb, 06:29 |
| Debabrata Ghosh |
Environment variable for deleting .sparkStaging |
Thu, 13 Feb, 13:06 |
| mailford...@gmail.com |
Re: Environment variable for deleting .sparkStaging |
Thu, 13 Feb, 18:05 |
| Enrico Minack |
Re: Questions about count() performance with dataframes and parquet files |
Thu, 13 Feb, 18:13 |
| Ashley Hoff |
Re: Questions about count() performance with dataframes and parquet files |
Fri, 14 Feb, 01:39 |
| Vinod Kancharana |
Spark 2.4.4 with Hive 2.3.6 |
Fri, 14 Feb, 17:09 |
| Ruijing Li |
Spark 2.4.4 has bigger memory impact than 2.3? |
Sat, 15 Feb, 15:37 |
| Ruijing Li |
Re: Best way to read batch from Kafka and Offsets |
Sat, 15 Feb, 15:41 |
| Burak Yavuz |
Re: Best way to read batch from Kafka and Offsets |
Sun, 16 Feb, 04:16 |
| kant kodali |
Connected components using GraphFrames is significantly slower than GraphX? |
Sun, 16 Feb, 11:41 |
| Subash Prabakar |
Apache Arrow support for Apache Spark |
Mon, 17 Feb, 07:41 |
| Zhefu PENG |
[ML] [How-to]: How to unload the loaded W2V model in Pyspark? |
Mon, 17 Feb, 13:10 |
| Chris Teoh |
Re: Apache Arrow support for Apache Spark |
Mon, 17 Feb, 13:31 |
| Mich Talebzadeh |
Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 14:43 |
| Muthu Jayakumar |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 20:27 |
| Nicolas PARIS |
Re: Questions about count() performance with dataframes and parquet files |
Mon, 17 Feb, 21:06 |
| Mich Talebzadeh |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 21:15 |
| Muthu Jayakumar |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 21:33 |
| Jörn Franke |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 21:33 |
| Mich Talebzadeh |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 21:37 |
| Mich Talebzadeh |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Mon, 17 Feb, 22:27 |
| Enrico Minack |
Re: Questions about count() performance with dataframes and parquet files |
Tue, 18 Feb, 07:38 |
| Nicolas PARIS |
Re: Questions about count() performance with dataframes and parquet files |
Tue, 18 Feb, 08:26 |
| Ruijing Li |
Better way to debug serializable issues |
Tue, 18 Feb, 10:01 |
| Maxim Gekk |
Re: Better way to debug serializable issues |
Tue, 18 Feb, 18:24 |
| julio.ces...@free.fr |
unsubscribe |
Wed, 19 Feb, 13:40 |
| Srinivasaraghavan, Vinod |
RE: unsubscribe |
Wed, 19 Feb, 13:41 |
| Alexey Kovyazin |
unsubscribe |
Wed, 19 Feb, 16:00 |
| Pramod Biligiri |
Spark Streaming job having issue with Java Flight Recorder (JFR) |
Thu, 20 Feb, 12:12 |
| Aelur Sadgod |
CBO not working? |
Thu, 20 Feb, 13:36 |
| Sol Rodriguez |
Re: CBO not working? |
Thu, 20 Feb, 14:38 |
| Ruijing Li |
Re: Better way to debug serializable issues |
Fri, 21 Feb, 00:29 |
| Ruijing Li |
Integration testing Framework Spark SQL Scala |
Fri, 21 Feb, 02:09 |
| ard3nte |
Spark RDD ouput path for data lineage |
Fri, 21 Feb, 09:40 |
| Nikhil Goyal |
Serialization error when using scala kernel with Jupyter |
Fri, 21 Feb, 19:28 |
| Apostolos N. Papadopoulos |
Re: Serialization error when using scala kernel with Jupyter |
Fri, 21 Feb, 19:54 |
| Monish R |
PowerIterationClustering |
Sat, 22 Feb, 00:48 |
| Kshitij |
Does dataframe spark API write/create a single file instead of directory as a result of write operation. |
Sat, 22 Feb, 05:20 |
| Kshitij |
Re: Does dataframe spark API write/create a single file instead of directory as a result of write operation. |
Sat, 22 Feb, 10:38 |
| Sebastian Piu |
Re: Does dataframe spark API write/create a single file instead of directory as a result of write operation. |
Sat, 22 Feb, 10:45 |
| Kshitij |
Re: Does dataframe spark API write/create a single file instead of directory as a result of write operation. |
Sat, 22 Feb, 10:47 |
| JARDIN Yohann |
Re: Does dataframe spark API write/create a single file instead of directory as a result of write operation. |
Sat, 22 Feb, 12:01 |
| Nicolas PARIS |
Re: Does dataframe spark API write/create a single file instead of directory as a result of write operation. |
Sat, 22 Feb, 22:52 |
| Proust (Feng Guizhou) [Travel Search & Discovery] |
[Spark SQL] NegativeArraySizeException When Parse InternalRow to DTO Field with Type Array[String] |
Sun, 23 Feb, 08:08 |
| Sandeep Patra |
Re: [Spark SQL] NegativeArraySizeException When Parse InternalRow to DTO Field with Type Array[String] |
Sun, 23 Feb, 12:04 |
| Mich Talebzadeh |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Sun, 23 Feb, 19:13 |
| Sean Busbey |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Sun, 23 Feb, 19:54 |
| Jörn Franke |
Re: Spark reading from Hbase throws java.lang.NoSuchMethodError: org.json4s.jackson.JsonMethods |
Sun, 23 Feb, 20:15 |
| dpristin |
setting initial state for mapGroupsWithState |
Mon, 24 Feb, 15:41 |
| Anthony PONCET |
[SPARK Dependencies] Security Vulnerability with Xerces version < 2.12 |
Mon, 24 Feb, 17:05 |
| Jianneng Li |
[Spark SQL] Memory problems with packing too many joins into the same WholeStageCodegen |
Tue, 25 Feb, 02:15 |
| Liu Genie |
Re: [Spark SQL] Memory problems with packing too many joins into the same WholeStageCodegen |
Tue, 25 Feb, 02:39 |
| Jianneng Li |
Re: [Spark SQL] Memory problems with packing too many joins into the same WholeStageCodegen |
Tue, 25 Feb, 03:06 |
| yeikel valdes |
Re: [Spark SQL] Memory problems with packing too many joins into the same WholeStageCodegen |
Tue, 25 Feb, 13:48 |
| Proust (Feng Guizhou) [Travel Search & Discovery] |
Re: [Spark SQL] NegativeArraySizeException When Parse InternalRow to DTO Field with Type Array[String] |
Tue, 25 Feb, 15:28 |
| Proust (Feng Guizhou) [Travel Search & Discovery] |
Re: [Spark SQL] NegativeArraySizeException When Parse InternalRow to DTO Field with Type Array[String] |
Tue, 25 Feb, 15:30 |
| yeikel valdes |
What options do I have to handle third party classes that are not serializable? |
Tue, 25 Feb, 16:23 |
| Jeff Evans |
Re: What options do I have to handle third party classes that are not serializable? |
Tue, 25 Feb, 16:25 |
| Ruijing Li |
Re: Integration testing Framework Spark SQL Scala |
Tue, 25 Feb, 18:46 |
| Aniruddha P Tekade |
Standard practices for building dashboards for spark processed data |
Wed, 26 Feb, 01:23 |
| Jianneng Li |
Re: [Spark SQL] Memory problems with packing too many joins into the same WholeStageCodegen |
Wed, 26 Feb, 01:32 |
| Roland Johann |
Re: Standard practices for building dashboards for spark processed data |
Wed, 26 Feb, 07:36 |
| Enrico Minack |
[SPARK-30957][SQL] Null-safe variant of Dataset.join(Dataset[_], Seq[String]) |
Wed, 26 Feb, 09:07 |
| Liu Genie |
Re: [Spark SQL] Memory problems with packing too many joins into the same WholeStageCodegen |
Wed, 26 Feb, 11:58 |
| Aniruddha P Tekade |
Re: [External Email] Re: Standard practices for building dashboards for spark processed data |
Wed, 26 Feb, 19:16 |