diff --git a/notebooks/spark-example.ipynb b/notebooks/spark-example.ipynb index b39dfda..267526f 100644 --- a/notebooks/spark-example.ipynb +++ b/notebooks/spark-example.ipynb @@ -79,7 +79,7 @@ "outputs": [], "source": [ "print('startingggg', datetime.now().strftime('%Y-%m-%d %H:%M:%S'))\n", - "tcp_interactions.write.format('csv').save(\"/results/spark-result\", sep='|', header=True)\n", + "tcp_interactions.write.format('csv').mode('overwrite').save(\"/results/spark-result\", sep='|', header=True)\n", "print('endingggg', datetime.now().strftime('%Y-%m-%d %H:%M:%S'))" ] },