Repository: spark Updated Branches: refs/heads/master c84acd4aa -> 19bcd6ab1
[HOTFIX] - Disable Kinesis tests due to rate limits Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/19bcd6ab Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/19bcd6ab Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/19bcd6ab Branch: refs/heads/master Commit: 19bcd6ab12bf355bc5d774905ec7fe3b5fc8e0e2 Parents: c84acd4 Author: Patrick Wendell <[email protected]> Authored: Fri Jul 24 22:57:01 2015 -0700 Committer: Patrick Wendell <[email protected]> Committed: Fri Jul 24 22:57:01 2015 -0700 ---------------------------------------------------------------------- .../org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/19bcd6ab/extras/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala ---------------------------------------------------------------------- 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 f9c952b..4992b04 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() --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
