Github user pwendell commented on the pull request:
https://github.com/apache/spark/pull/2216#issuecomment-57060863
Yeah so I looked into it a bit more and since `JavaDStream` extends
`JavaDStreamLike` this will break user code with custom DStream's. The issue is
that under the hood those user classes have been compiled to implement an
interface called `JavaDStreamLike` and older ones won't have the forwarder
method in the interface.
In this case I think there is a straightforward workaround of just adding
`print(num)`. To the concrete classes `JavaDStream` and `JavaPairDStream`. It
will have some code re-use both with `print` and with each other, but it will
work.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
