diff --git a/pkg/source/kinesis/kinesis_source.go b/pkg/source/kinesis/kinesis_source.go
index d164a756..f50705d0 100644
--- a/pkg/source/kinesis/kinesis_source.go
+++ b/pkg/source/kinesis/kinesis_source.go
@@ -269,7 +269,7 @@ func (ks *kinesisSource) Read(sf *sourceiface.SourceFunctions) error {
 	case <-time.After(10 * time.Second):
 		// Append errors and crash
 		multierror.Append(kinesisPullErr, errors.Errorf("wg.Wait() took too long, forcing app close."))
-		ks.log.WithFields(log.Fields{"error": kinesisPullErr}).Fatal(kinesisPullErr)
+		ks.log.WithFields(log.Fields{"error": err}).Fatal(err)
 	}
 
 	// Return kinesisPullErr if we have one
diff --git a/pkg/source/sqs/sqs_source_test.go b/pkg/source/sqs/sqs_source_test.go
index 95f3c8a3..f7fc0a18 100644
--- a/pkg/source/sqs/sqs_source_test.go
+++ b/pkg/source/sqs/sqs_source_test.go
@@ -67,7 +67,7 @@ func TestNewSQSSourceWithInterfaces_Success(t *testing.T) {
 }
 
 // newSQSSourceWithInterfaces should fail if we can't reach SQS
-func TestNewSQSSourceWithInterfaces_SQSConnectioNFailure(t *testing.T) {
+func TestNewSQSSourceWithInterfaces_SQSConnectionFailure(t *testing.T) {
 	// Unlike the success test, we don't require anything to exist for this one
 	assert := assert.New(t)