[ 
https://issues.apache.org/jira/browse/SPARK-19715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15884230#comment-15884230
 ] 

Steve Loughran commented on SPARK-19715:
----------------------------------------

OK. I'd recommend going twith Path.getURI.getPath() to get the full path, 
though there's the always the risk of >1 s3a bucket referring to the same 
objects

Some filesystems (HDFS, file:) have checksums you can ask for, though S3a 
doesn't, yet: HADOOP-13282 has discussed serving up etags, primarily to aid 
distcp updates. If added, you could use that as the differentiator, or at least 
to identify changed files

To be ruthless, it may have been simpler for the user just to edit the 
fs.s3n.impl binding to point to S3AFileSystem.class & then left the URLs the 
same

> Option to Strip Paths in FileSource
> -----------------------------------
>
>                 Key: SPARK-19715
>                 URL: https://issues.apache.org/jira/browse/SPARK-19715
>             Project: Spark
>          Issue Type: New Feature
>          Components: Structured Streaming
>    Affects Versions: 2.1.0
>            Reporter: Michael Armbrust
>
> Today, we compare the whole path when deciding if a file is new in the 
> FileSource for structured streaming.  However, this cause cause false 
> negatives in the case where the path has changed in a cosmetic way (i.e. 
> changing s3n to s3a).  We should add an option {{fileNameOnly}} that causes 
> the new file check to be based only on the filename (but still store the 
> whole path in the log).



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org

Reply via email to