Commit 3628242
[MINOR][DSTREAMS] Add DStreamCheckpointData.cleanup warning if delete returns false
## What changes were proposed in this pull request?
While I was reviewing apache#24235 I've found a minor addition possibility. Namely `FileSystem.delete` returns a boolean which is not yet checked. In this PR I've added a warning message when it returns false. I've added this as MINOR because no control flow change introduced.
## How was this patch tested?
Existing unit tests.
Closes apache#24263 from gaborgsomogyi/SPARK-27301-minor.
Authored-by: Gabor Somogyi <[email protected]>
Signed-off-by: Sean Owen <[email protected]>1 parent d7dd59a commit 3628242
File tree
1 file changed
+5
-2
lines changed- streaming/src/main/scala/org/apache/spark/streaming/dstream
1 file changed
+5
-2
lines changedLines changed: 5 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
87 | 87 | | |
88 | 88 | | |
89 | 89 | | |
90 | | - | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
91 | 95 | | |
92 | | - | |
93 | 96 | | |
94 | 97 | | |
95 | 98 | | |
| |||
0 commit comments