Skip to content
Snippets Groups Projects
Commit 311fab6f authored by Tathagata Das's avatar Tathagata Das
Browse files

[SPARK-7722] [STREAMING] Added Kinesis to style checker

Author: Tathagata Das <tathagata.das1565@gmail.com>

Closes #6325 from tdas/SPARK-7722 and squashes the following commits:

9ab35b2 [Tathagata Das] Fixed styles in Kinesis
parent cdc7c055
No related branches found
No related tags found
No related merge requests found
...@@ -17,11 +17,11 @@ ...@@ -17,11 +17,11 @@
# limitations under the License. # limitations under the License.
# #
echo -e "q\n" | build/sbt -Phive -Phive-thriftserver scalastyle > scalastyle.txt echo -e "q\n" | build/sbt -Pkinesis-asl -Phive -Phive-thriftserver scalastyle > scalastyle.txt
echo -e "q\n" | build/sbt -Phive -Phive-thriftserver test:scalastyle >> scalastyle.txt echo -e "q\n" | build/sbt -Pkinesis-asl -Phive -Phive-thriftserver test:scalastyle >> scalastyle.txt
# Check style with YARN built too # Check style with YARN built too
echo -e "q\n" | build/sbt -Pyarn -Phadoop-2.2 scalastyle >> scalastyle.txt echo -e "q\n" | build/sbt -Pkinesis-asl -Pyarn -Phadoop-2.2 scalastyle >> scalastyle.txt
echo -e "q\n" | build/sbt -Pyarn -Phadoop-2.2 test:scalastyle >> scalastyle.txt echo -e "q\n" | build/sbt -Pkinesis-asl -Pyarn -Phadoop-2.2 test:scalastyle >> scalastyle.txt
ERRORS=$(cat scalastyle.txt | awk '{if($1~/error/)print}') ERRORS=$(cat scalastyle.txt | awk '{if($1~/error/)print}')
rm scalastyle.txt rm scalastyle.txt
......
...@@ -57,7 +57,7 @@ class KinesisReceiverSuite extends TestSuiteBase with Matchers with BeforeAndAft ...@@ -57,7 +57,7 @@ class KinesisReceiverSuite extends TestSuiteBase with Matchers with BeforeAndAft
var checkpointStateMock: KinesisCheckpointState = _ var checkpointStateMock: KinesisCheckpointState = _
var currentClockMock: Clock = _ var currentClockMock: Clock = _
override def beforeFunction() = { override def beforeFunction(): Unit = {
receiverMock = mock[KinesisReceiver] receiverMock = mock[KinesisReceiver]
checkpointerMock = mock[IRecordProcessorCheckpointer] checkpointerMock = mock[IRecordProcessorCheckpointer]
checkpointClockMock = mock[ManualClock] checkpointClockMock = mock[ManualClock]
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment