Treat an uncaught exception. Thank you, @juanyunism.

Author: cosmincatalin

src/main/scala/com/audienceproject/spark/dynamodb/datasource/TypeConversion.scala

@@ -20,7 +20,7 @@
   */
 package com.audienceproject.spark.dynamodb.datasource
 
-import com.amazonaws.services.dynamodbv2.document.Item
+import com.amazonaws.services.dynamodbv2.document.{IncompatibleTypeException, Item}
 import org.apache.spark.sql.catalyst.InternalRow
 import org.apache.spark.sql.catalyst.util.{ArrayBasedMapData, GenericArrayData}
 import org.apache.spark.sql.types._
@@ -87,6 +87,7 @@ private[dynamodb] object TypeConversion {
     private def nullableGet(getter: Item => String => Any)(attrName: String): Item => Any = {
         case item if item.hasAttribute(attrName) => try getter(item)(attrName) catch {
             case _: NumberFormatException => null
+            case _: IncompatibleTypeException => null
         }
         case _ => null
     }

src/test/scala/com/audienceproject/spark/dynamodb/NullBooleanTest.scala

@@ -0,0 +1,53 @@
+package com.audienceproject.spark.dynamodb
+
+import com.amazonaws.services.dynamodbv2.document.Item
+import com.amazonaws.services.dynamodbv2.model.{
+    AttributeDefinition,
+    CreateTableRequest,
+    KeySchemaElement,
+    ProvisionedThroughput
+}
+import com.audienceproject.spark.dynamodb.implicits._
+
+class NullBooleanTest extends AbstractInMemoryTest {
+    test("Test Null") {
+        dynamoDB.createTable(
+            new CreateTableRequest()
+                .withTableName("TestNullBoolean")
+                .withAttributeDefinitions(new AttributeDefinition("Pk", "S"))
+                .withKeySchema(new KeySchemaElement("Pk", "HASH"))
+                .withProvisionedThroughput(new ProvisionedThroughput(5L, 5L))
+        )
+
+        val table = dynamoDB.getTable("TestNullBoolean")
+
+        for ((_pk, _type, _value) <- Seq(
+            ("id1", "type1", true),
+            ("id2", "type2", null)
+        )) {
+            if (_type != "type2") {
+                table.putItem(
+                    new Item()
+                        .withString("Pk", _pk)
+                        .withString("Type", _type)
+                        .withBoolean("Value", _value.asInstanceOf[Boolean])
+                )
+            } else {
+                table.putItem(
+                    new Item()
+                        .withString("Pk", _pk)
+                        .withString("Type", _type)
+                        .withNull("Value")
+                )
+            }
+        }
+
+        val df = spark.read.dynamodbAs[BooleanClass]("TestNullBoolean")
+
+        import spark.implicits._
+        df.where($"Type" === "type2").show()
+        client.deleteTable("TestNullBoolean")
+    }
+}
+
+case class BooleanClass(Pk: String, Type: String, Value: Boolean)