Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
1.8.0
-
None
Description
Currently KuduContext does not support Spark Streaming DataFrame. The problem comes from a foreachPartition call which in case of spark streaming is an unsupported operation, like foreach:
unsupported operations in streaming
I have created a small example app with a custom Kudu sink which can be used for testing:
kudu custom sink and example app
The patch fixing this issue is also available for kudu-spark, so soon a gerrit review can be expected with the solution.