fix: Fixes types comparison (#353)

googleapis · Jan 27, 2022 · 451901a · 451901a
1 parent 2739f69
commit 451901a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git 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
@@ -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 "