diff --git a/services/streammanager/bqstream/bqstreammanager_test.go b/services/streammanager/bqstream/bqstreammanager_test.go
index f8320b8c04..3a2184a759 100644
--- a/services/streammanager/bqstream/bqstreammanager_test.go
+++ b/services/streammanager/bqstream/bqstreammanager_test.go
@@ -147,7 +147,7 @@ func TestInvalidCredentials(t *testing.T) {
 	_, err = bqstream.NewProducer(&destination, common.Opts{Timeout: 1 * time.Microsecond})
 
 	assert.NotNil(t, err)
-	assert.EqualError(t, err, "bigquery: constructing client: missing 'type' field in credentials")
+	assert.EqualError(t, err, "bigquery: constructing client: credentials: unsupported filetype '\\x00'")
 }
 
 func TestProduceWithInvalidClient(t *testing.T) {
diff --git a/services/streammanager/streammanager_suite_test.go b/services/streammanager/streammanager_suite_test.go
index 1b953dc0ea..059e979e94 100644
--- a/services/streammanager/streammanager_suite_test.go
+++ b/services/streammanager/streammanager_suite_test.go
@@ -200,7 +200,7 @@ func TestNewProducerWithBQStreamDestination(t *testing.T) {
 						"project_id": "",
 						"private_key_id": "",
 						"private_key": "-----BEGIN PRIVATE KEY----------END PRIVATE KEY-----\n",
-						"client_email": "",
+						"client_email": "foo@barr.com",
 						"client_id": "",
 						"auth_uri": "https://accounts.google.com/o/oauth2/auth",
 						"token_uri": "https://oauth2.googleapis.com/token",