diff options
| author | Luciano Resende <lresende@apache.org> | 2017-01-18 12:39:20 -0800 |
|---|---|---|
| committer | Luciano Resende <lresende@apache.org> | 2017-01-18 12:39:20 -0800 |
| commit | a780322f8fa4a6621ab14f6cbccc06a7a124df1d (patch) | |
| tree | 1b596c2e65e0c9a0a798af37165c56b5efd766f4 | |
| parent | 4396417e190364d9e638fe99548652842399a438 (diff) | |
| download | toree-gateway-a780322f8fa4a6621ab14f6cbccc06a7a124df1d.tar.gz toree-gateway-a780322f8fa4a6621ab14f6cbccc06a7a124df1d.tar.bz2 toree-gateway-a780322f8fa4a6621ab14f6cbccc06a7a124df1d.zip | |
Convert result to plain text before returning
| -rw-r--r-- | src/main/scala/com/ibm/ToreeGateway.scala | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/main/scala/com/ibm/ToreeGateway.scala b/src/main/scala/com/ibm/ToreeGateway.scala index 48dd6f7..e002ecb 100644 --- a/src/main/scala/com/ibm/ToreeGateway.scala +++ b/src/main/scala/com/ibm/ToreeGateway.scala @@ -39,9 +39,8 @@ class ToreeGateway(client: SparkKernelClient) { private def handleResult(promise:Promise[String], result: ExecuteResult) = { log.warn(s"Result was: ${result.data(MIMEType.PlainText)}") - // promise.success(result.data(MIMEType.PlainText)) - promise.success(result.content) - + promise.success(result.data(MIMEType.PlainText)) + //promise.success(result.content) } private def handleSuccess(promise:Promise[String], executeReplyOk: ExecuteReplyOk) = { |