This is an automated email from the ASF dual-hosted git repository.
lresende pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-toree.git
The following commit(s) were added to refs/heads/master by this push:
new fb8368b3 [TOREE-540] Remove accident debugging changes (#206)
fb8368b3 is described below
commit fb8368b3353569715eaf4c00b12f26ccd7ea37e1
Author: Cheng Pan <[email protected]>
AuthorDate: Mon Aug 7 00:43:43 2023 +0800
[TOREE-540] Remove accident debugging changes (#206)
---
.../org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala
b/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala
index 1ac7f08e..a515e946 100644
---
a/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala
+++
b/communication/src/main/scala/org/apache/toree/communication/socket/ZeroMQSocketRunnable.scala
@@ -64,7 +64,7 @@ class ZeroMQSocketRunnable(
*/
protected def processOptions(socket: ZMQ.Socket): Unit = {
val socketOptionsString = socketOptions.map("\n- " +
_.toString).mkString("")
- logger.info(
+ logger.trace(
s"Processing options for socket $socketType: $socketOptionsString"
)
@@ -103,7 +103,7 @@ class ZeroMQSocketRunnable(
*/
protected def processNextOutboundMessage(socket: ZMQ.Socket): Boolean = {
val message = Option(outboundMessages.poll())
- message.foreach(msg => println(s"send: \n$msg"))
+
message.foreach(_.send(socket))
message.nonEmpty