diff --git a/pom.xml b/pom.xml
index d62b9e00..1d3499e6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -111,7 +111,6 @@
       <groupId>org.scala-lang</groupId>
       <artifactId>scala-library</artifactId>
       <version>${scala.version}</version>
-      <scope>provided</scope>
     </dependency>
     <dependency>
       <groupId>org.scala-lang.modules</groupId>
diff --git a/src/main/java/com/google/cloud/pubsublite/spark/PslSparkUtils.java b/src/main/java/com/google/cloud/pubsublite/spark/PslSparkUtils.java
index 066a1eae..cbf7969b 100644
--- a/src/main/java/com/google/cloud/pubsublite/spark/PslSparkUtils.java
+++ b/src/main/java/com/google/cloud/pubsublite/spark/PslSparkUtils.java
@@ -176,7 +176,7 @@ public static void verifyWriteInputSchema(StructType inputSchema) {
           Option<Object> idxOr = inputSchema.getFieldIndex(k);
           if (!idxOr.isEmpty()) {
             StructField f = inputSchema.apply((int) idxOr.get());
-            if (f.dataType() != v) {
+            if (!f.dataType().sameType(v)) {
               throw new IllegalArgumentException(
                   String.format(
                       "Column %s in input schema to write to "