diff options
author | Patrick Wendell <patrick@databricks.com> | 2015-07-24 22:57:01 -0700 |
---|---|---|
committer | Patrick Wendell <patrick@databricks.com> | 2015-07-24 22:57:01 -0700 |
commit | 19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2 (patch) | |
tree | 1587d33e47589f9c55390f2444943473466591d7 /extras/kinesis-asl | |
parent | c84acd4aa4f8bee98baa550cd6801c797a8a7a25 (diff) | |
download | spark-19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2.tar.gz spark-19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2.tar.bz2 spark-19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2.zip |
[HOTFIX] - Disable Kinesis tests due to rate limits
Diffstat (limited to 'extras/kinesis-asl')
-rw-r--r-- | extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala | 4 |
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() |