- Build a fat jar with ./gradlew clean build shadowJar
- Run the created jar file ./build/libs/spark-streaming-test-all.jar with
java -jar build/libs/spark-streaming-test-all.jar - Uncomment line 18 in
Application.javato see the infinte loop error.
-
Notifications
You must be signed in to change notification settings - Fork 0
An example repo to show that parallel streaming with custom receiver is not possible with Spark Streaming.
License
muthenberg/spark-streaming-custom-parallel-streams
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
An example repo to show that parallel streaming with custom receiver is not possible with Spark Streaming.
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published