[FLINK-9317] Async I/O API Example For Scala has Variable Name error

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.4.2
• Fix Version/s: 1.4.3, 1.5.0
• Component/s: Documentation
• Labels: documentation
• Assignee: Unassigned
• Reporter: Yazdan Shirvany
• Created: 09/May/18 05:28
• Updated: 10/May/18 11:53
• Resolved: 10/May/18 11:53

Description

Async I/O API Scala Example has duplicated resultFuture variable with different data type.

 

resultFuture: ResultFuture[(String, String)]

val resultFuture: Future[String]

 

this cause error on compile as variables have same naming.

 

In order to example works properly we need to update variable names to be distinct,

 

```

override def asyncInvoke(input: (String,String, String), resultFuture: ResultFuture[(String,String, String, String)]): Unit = {

// issue the asynchronous request, receive a future for the result
val resultFutureRequested: Future[String] = Future

{ // client2.query(str) client.getAccountReferenceId(token, input._1) }

// set the callback to be executed once the request by the client is complete
// the callback simply forwards the result to the result future
resultFutureRequested.onSuccess {
case result: String =>

{ resultFuture.complete(Iterable((input._1, input._2, input._3, result))) }

}
}

```

 

 

Issue Links

• links to: GitHub Pull Request #5968