Merge branch 'master' of https://github.com/hdinsight/spark-eventhubs

Azure · Mar 16, 2017 · c3be247 · c3be247
2 parents 43a9ef3 + f687de7
commit c3be247
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/.gitignore b/.gitignore
@@ -7,3 +7,4 @@ target/
 *.iml
 scalastyle-output.xml
 dependency-reduced-pom.xml
+metastore_db
diff --git a/core/src/main/scala/org/apache/spark/streaming/eventhubs/RestfulEventHubClient.scala b/core/src/main/scala/org/apache/spark/streaming/eventhubs/RestfulEventHubClient.scala
@@ -109,7 +109,7 @@ private[eventhubs] class RestfulEventHubClient(
             header("Content-Type", "application/atom+xml;type=entry;charset=utf-8").
             timeout(connTimeoutMs = 3000, readTimeoutMs = 30000).asString
           if (response.code != 200) {
-            if (!retryIfFail || retryTime > RETRY_INTERVAL_SECONDS.length) {
+            if (!retryIfFail || retryTime > RETRY_INTERVAL_SECONDS.length - 1) {
               val errorInfoString = s"cannot get latest offset of" +
                 s" $ehNameAndPartition, status code: ${response.code}, ${response.headers}" +
                 s" returned error:" +