Merge pull request Azure#407 from revinjchalil/2.4

Fixes null pointer exception in streaming schema inference

Author: FabianMeiswinkel

CHANGELOG.md

@@ -1,3 +1,6 @@
+### 3.3.1
+- Fixes null pointer exception in streaming schema inference. 
+
 ### 3.3.0
 - Adds a new config option "changefeedstartfromdatetime" that can be used to specify from when the changefeed should be processed. See [Config options](https://github.com/Azure/azure-cosmosdb-spark/wiki/Configuration-references) for details.
 

pom.xml

@@ -21,7 +21,7 @@ limitations under the License.
     <groupId>com.microsoft.azure</groupId>
     <artifactId>azure-cosmosdb-spark_2.4.0_2.11</artifactId>
     <packaging>jar</packaging>
-    <version>3.3.0</version>
+    <version>3.3.1</version>
     <name>${project.groupId}:${project.artifactId}</name>
     <description>Spark Connector for Microsoft Azure CosmosDB</description>
     <url>http://azure.microsoft.com/en-us/services/documentdb/</url>

src/main/scala/com/microsoft/azure/cosmosdb/spark/Constants.scala

@@ -23,6 +23,6 @@
 package com.microsoft.azure.cosmosdb.spark
 
 object Constants {
-  val currentVersion = "2.4.0_2.11-3.2.0"
+  val currentVersion = "2.4.0_2.11-3.3.1"
   val userAgentSuffix = s" SparkConnector/$currentVersion"
 }

src/main/scala/com/microsoft/azure/cosmosdb/spark/streaming/CosmosDBSource.scala

@@ -88,8 +88,7 @@ private[spark] class CosmosDBSource(sqlContext: SQLContext,
       val helperDfConfig: Map[String, String] = streamConfigMap
         .-(CosmosDBConfig.ChangeFeedStartFromTheBeginning)
         .+((CosmosDBConfig.ChangeFeedStartFromTheBeginning, String.valueOf(false)))
-        .-(CosmosDBConfig.ChangeFeedStartFromDateTime).
-        +((CosmosDBConfig.ChangeFeedStartFromDateTime,null))
+        .-(CosmosDBConfig.ChangeFeedStartFromDateTime)
         .-(CosmosDBConfig.ReadChangeFeed).
         +((CosmosDBConfig.ReadChangeFeed, String.valueOf(false)))
         .-(CosmosDBConfig.QueryCustom).