[SPARK-17569] Don't recheck existence of files when generating File Relation resolution in StructuredStreaming - ASF JIRA

Rank to Top

Rank to Bottom

Attach files

Attach Screenshot

Bulk Copy Attachments

Bulk Move Attachments

Voters

Watch issue

Watchers

Create sub-task

Convert to sub-task

Link

Clone

Labels

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Improvement
Status: Resolved
Priority: Major
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 2.0.1, 2.1.0
Component/s: None
Labels:
None

Description

Structured Streaming's FileSource lists files to classify files as Offsets. Once this file list is committed to a metadata log for a batch, this file list is turned into a "Batch FileSource" Relation which acts as the source to the incremental execution.

While this "Batch FileSource" Relation is resolved, we re-check that every single file exists on the Driver. It takes a horrible amount of time, and is a total waste. We can simply skip file existence during execution.