diff --git a/project/Dependencies.scala b/project/Dependencies.scala
index 6a7ce923..2a1df8f0 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -1,13 +1,13 @@
 import sbt._
 
 object Dependencies {
-  val scio = "com.spotify" %% "scio-core" % "0.13.6"
+  val scio = "com.spotify" %% "scio-core" % "0.14.0"
 
-  val scioGcp = "com.spotify" %% "scio-google-cloud-platform" % "0.13.6" excludeAll (
+  val scioGcp = "com.spotify" %% "scio-google-cloud-platform" % "0.14.0" excludeAll (
     ExclusionRule(organization = "org.apache.beam", name = "beam-runners-direct-java")
   )
 
-  val scioTest = "com.spotify" %% "scio-test" % "0.13.6" excludeAll (
+  val scioTest = "com.spotify" %% "scio-test" % "0.14.0" excludeAll (
     ExclusionRule(organization = "org.apache.beam", name = "beam-runners-direct-java")
   )
 
diff --git a/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala b/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala
index a53e6d84..9430e915 100644
--- a/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala
+++ b/stream-processing-test/src/main/scala/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesFactory.scala
@@ -12,4 +12,7 @@ object BigQueryServicesFactory extends BigQueryServices {
 
   override def getStorageClient(options: BigQueryOptions): BigQueryServices.StorageClient =
     new BigQueryServicesImpl().getStorageClient(options)
+
+  override def getWriteStreamService(options: BigQueryOptions): BigQueryServices.WriteStreamService =
+    new BigQueryServicesImpl().getWriteStreamService(options)
 }