<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>topic Re: Why is my streaming job not resuming even though I specified checkpoint directory in Data Engineering</title>
    <link>https://community.databricks.com/t5/data-engineering/why-is-my-streaming-job-not-resuming-even-though-i-specified/m-p/19843#M13372</link>
    <description>&lt;P&gt;This is a common question from many users. If the streaming checkpoint directory is specified correctly then this behavior is expected.&amp;nbsp;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Below is an example of specifying the checkpoint correctly&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;PRE&gt;&lt;CODE&gt;df.writeStream
&amp;nbsp;
 .format("parquet")
&amp;nbsp;
 .option("checkpointLocation", "path/to/checkpoint/dir")
&amp;nbsp;
 .option("path", "path/to/destination/dir")
&amp;nbsp;
 .start()&lt;/CODE&gt;&lt;/PRE&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Instead, if you are specifying the checkpointLocation as readStream option it's ignored. One other common scenario where the option is ignored is when you specify the checkpointLocation as an option for the write operation within the forEachBatch.&amp;nbsp;The option should be provided for the writeStream API&lt;/P&gt;</description>
    <pubDate>Fri, 25 Jun 2021 13:34:46 GMT</pubDate>
    <dc:creator>brickster_2018</dc:creator>
    <dc:date>2021-06-25T13:34:46Z</dc:date>
    <item>
      <title>Why is my streaming job not resuming even though I specified checkpoint directory</title>
      <link>https://community.databricks.com/t5/data-engineering/why-is-my-streaming-job-not-resuming-even-though-i-specified/m-p/19842#M13371</link>
      <description>&lt;P&gt;I have provided the checkpointLocation as below, however I see the config is ignored for my streaming query&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;B&gt;&lt;I&gt;option("checkpointLocation", "path/to/checkpoint/dir")&lt;/I&gt;&lt;/B&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;</description>
      <pubDate>Fri, 25 Jun 2021 13:33:55 GMT</pubDate>
      <guid>https://community.databricks.com/t5/data-engineering/why-is-my-streaming-job-not-resuming-even-though-i-specified/m-p/19842#M13371</guid>
      <dc:creator>brickster_2018</dc:creator>
      <dc:date>2021-06-25T13:33:55Z</dc:date>
    </item>
    <item>
      <title>Re: Why is my streaming job not resuming even though I specified checkpoint directory</title>
      <link>https://community.databricks.com/t5/data-engineering/why-is-my-streaming-job-not-resuming-even-though-i-specified/m-p/19843#M13372</link>
      <description>&lt;P&gt;This is a common question from many users. If the streaming checkpoint directory is specified correctly then this behavior is expected.&amp;nbsp;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Below is an example of specifying the checkpoint correctly&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;PRE&gt;&lt;CODE&gt;df.writeStream
&amp;nbsp;
 .format("parquet")
&amp;nbsp;
 .option("checkpointLocation", "path/to/checkpoint/dir")
&amp;nbsp;
 .option("path", "path/to/destination/dir")
&amp;nbsp;
 .start()&lt;/CODE&gt;&lt;/PRE&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;&lt;/P&gt;&lt;P&gt;Instead, if you are specifying the checkpointLocation as readStream option it's ignored. One other common scenario where the option is ignored is when you specify the checkpointLocation as an option for the write operation within the forEachBatch.&amp;nbsp;The option should be provided for the writeStream API&lt;/P&gt;</description>
      <pubDate>Fri, 25 Jun 2021 13:34:46 GMT</pubDate>
      <guid>https://community.databricks.com/t5/data-engineering/why-is-my-streaming-job-not-resuming-even-though-i-specified/m-p/19843#M13372</guid>
      <dc:creator>brickster_2018</dc:creator>
      <dc:date>2021-06-25T13:34:46Z</dc:date>
    </item>
  </channel>
</rss>

