diff options
| author | jerryshao <sshao@hortonworks.com> | 2015-11-17 16:57:52 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-11-17 16:57:52 -0800 |
| commit | 75a292291062783129d02607302f91c85655975e (patch) | |
| tree | 7ba09e47b8aa3b3810bc3d115817a862a729aac0 /project | |
| parent | b362d50fca30693f97bd859984157bb8a76d48a1 (diff) | |
| download | spark-75a292291062783129d02607302f91c85655975e.tar.gz spark-75a292291062783129d02607302f91c85655975e.tar.bz2 spark-75a292291062783129d02607302f91c85655975e.zip | |
[SPARK-9065][STREAMING][PYSPARK] Add MessageHandler for Kafka Python API
Fixed the merge conflicts in #7410
Closes #7410
Author: Shixiong Zhu <shixiong@databricks.com>
Author: jerryshao <saisai.shao@intel.com>
Author: jerryshao <sshao@hortonworks.com>
Closes #9742 from zsxwing/pr7410.
Diffstat (limited to 'project')
| -rw-r--r-- | project/MimaExcludes.scala | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/project/MimaExcludes.scala b/project/MimaExcludes.scala index 8b3bc96801..eb70d27c34 100644 --- a/project/MimaExcludes.scala +++ b/project/MimaExcludes.scala @@ -136,6 +136,12 @@ object MimaExcludes { // SPARK-11766 add toJson to Vector ProblemFilters.exclude[MissingMethodProblem]( "org.apache.spark.mllib.linalg.Vector.toJson") + ) ++ Seq( + // SPARK-9065 Support message handler in Kafka Python API + ProblemFilters.exclude[MissingMethodProblem]( + "org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper.createDirectStream"), + ProblemFilters.exclude[MissingMethodProblem]( + "org.apache.spark.streaming.kafka.KafkaUtilsPythonHelper.createRDD") ) case v if v.startsWith("1.5") => Seq( |