diff options
author | jerryshao <saisai.shao@intel.com> | 2015-04-09 23:14:24 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-04-09 23:14:24 -0700 |
commit | 3290d2d13bb4bd875aec14425c8e3766f9cc644b (patch) | |
tree | 7e862fb443bd1bca2b15c3fd1a1ec9b9d27912d5 /dev | |
parent | e2360810f50de77f79d372cc9b46db117d451cfc (diff) | |
download | spark-3290d2d13bb4bd875aec14425c8e3766f9cc644b.tar.gz spark-3290d2d13bb4bd875aec14425c8e3766f9cc644b.tar.bz2 spark-3290d2d13bb4bd875aec14425c8e3766f9cc644b.zip |
[SPARK-6211][Streaming] Add Python Kafka API unit test
Refactor the Kafka unit test and add Python API support. CC tdas davies please help to review, thanks a lot.
Author: jerryshao <saisai.shao@intel.com>
Author: Saisai Shao <saisai.shao@intel.com>
Closes #4961 from jerryshao/SPARK-6211 and squashes the following commits:
ee4b919 [jerryshao] Fixed newly merged issue
82c756e [jerryshao] Address the comments
92912d1 [jerryshao] Address the commits
0708bb1 [jerryshao] Fix rebase issue
40b47a3 [Saisai Shao] Style fix
f889657 [Saisai Shao] Update the code according
8a2f3e2 [jerryshao] Address the issues
0f1b7ce [jerryshao] Still fix the bug
61a04f0 [jerryshao] Fix bugs and address the issues
64d9877 [jerryshao] Fix rebase bugs
8ad442f [jerryshao] Add kafka-assembly in run-tests
6020b00 [jerryshao] Add more debug info in Shell
8102d6e [jerryshao] Fix bug in Jenkins test
fde1213 [jerryshao] Code style changes
5536f95 [jerryshao] Refactor the Kafka unit test and add Python Kafka unittest support
Diffstat (limited to 'dev')
-rwxr-xr-x | dev/run-tests | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/dev/run-tests b/dev/run-tests index 1b6cf78b5d..bb21ab6c9a 100755 --- a/dev/run-tests +++ b/dev/run-tests @@ -173,7 +173,7 @@ CURRENT_BLOCK=$BLOCK_BUILD build/mvn $HIVE_BUILD_ARGS clean package -DskipTests else echo -e "q\n" \ - | build/sbt $HIVE_BUILD_ARGS package assembly/assembly \ + | build/sbt $HIVE_BUILD_ARGS package assembly/assembly streaming-kafka-assembly/assembly \ | grep -v -e "info.*Resolving" -e "warn.*Merging" -e "info.*Including" fi } |