Update core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/InstanceIdAssigner.scala

bdoyle0182 · style95 · web-flow · commit 221d76253302 · 2020-11-09T21:41:24.000-08:00
Co-authored-by: Dominic Kim &lt;style9595@gmail.com&gt;
diff --git a/core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/InstanceIdAssigner.scala b/core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/InstanceIdAssigner.scala
@@ -69,7 +69,7 @@ private[invoker] class InstanceIdAssigner(connectionString: String)(implicit log
           oldId
       }
     } else {
-      val newId = overwriteId.get
+      val newId = overwriteId.getOrElse("")
       zkClient.create().orSetData().forPath(myIdPath, BigInt(newId).toByteArray)
       logger.info(this, s"invokerReg: invoker $name was assigned invokerId $newId")
       newId

Original file line number	Diff line number	Diff line change
`@@ -69,7 +69,7 @@ private[invoker] class InstanceIdAssigner(connectionString: String)(implicit log`
`69`	`69`	`oldId`
`70`	`70`	`}`
`71`	`71`	`} else {`
`72`		`- val newId = overwriteId.get`
	`72`	`+ val newId = overwriteId.getOrElse("")`
`73`	`73`	`zkClient.create().orSetData().forPath(myIdPath, BigInt(newId).toByteArray)`
`74`	`74`	`logger.info(this, s"invokerReg: invoker $name was assigned invokerId $newId")`
`75`	`75`	`newId`