Commit cd46230
Andrew Or
Revert a small change that affected streaming
DStream#transform isn't cleaning closures correctly. It is passing
an RDD to ClosureCleaner#clean. We should fix this separately
outside of this patch.1 parent 0bbe77f commit cd46230
File tree
1 file changed
+0
-3
lines changed- core/src/main/scala/org/apache/spark/util
1 file changed
+0
-3
lines changedLines changed: 0 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
92 | 92 | | |
93 | 93 | | |
94 | 94 | | |
95 | | - | |
96 | | - | |
97 | | - | |
98 | 95 | | |
99 | 96 | | |
100 | 97 | | |
| |||
0 commit comments