aboutsummaryrefslogtreecommitdiff
path: root/extras
diff options
context:
space:
mode:
authorPatrick Wendell <patrick@databricks.com>2015-07-24 22:57:01 -0700
committerPatrick Wendell <patrick@databricks.com>2015-07-24 22:57:01 -0700
commit19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2 (patch)
tree1587d33e47589f9c55390f2444943473466591d7 /extras
parentc84acd4aa4f8bee98baa550cd6801c797a8a7a25 (diff)
downloadspark-19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2.tar.gz
spark-19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2.tar.bz2
spark-19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2.zip
[HOTFIX] - Disable Kinesis tests due to rate limits
Diffstat (limited to 'extras')
-rw-r--r--extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala b/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala
index f9c952b946..4992b04176 100644
--- a/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala
+++ b/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala
@@ -59,7 +59,7 @@ class KinesisStreamSuite extends KinesisFunSuite
}
}
- test("KinesisUtils API") {
+ ignore("KinesisUtils API") {
ssc = new StreamingContext(sc, Seconds(1))
// Tests the API, does not actually test data receiving
val kinesisStream1 = KinesisUtils.createStream(ssc, "mySparkStream",
@@ -83,7 +83,7 @@ class KinesisStreamSuite extends KinesisFunSuite
* you must have AWS credentials available through the default AWS provider chain,
* and you have to set the system environment variable RUN_KINESIS_TESTS=1 .
*/
- testIfEnabled("basic operation") {
+ ignore("basic operation") {
val kinesisTestUtils = new KinesisTestUtils()
try {
kinesisTestUtils.createStream()