Re: [Spark Structured Streaming]: truncated Parquet after driver crash or kill

2017-08-24 Thread cbowden
you shutdown gracefully, eg. invoke StreamingQuery#stop. https://issues.apache.org/jira/browse/SPARK-21029 is probably of interest. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Structured-Streaming-truncated-Parquet-after-driver-crash-or-kill

[Spark Structured Streaming]: truncated Parquet after driver crash or kill

2017-08-08 Thread dcam
iodically to deploy new versions of the code. We want to run the application as a long lived process that is continually reading from the Kafka queue and writing out to HDFS for archival purposes. Thanks, Dave Cameron -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.c