Clean up debug logging from ClickHouse 25.10 investigation

- Remove connection monitoring and query progress logging from HashSuite
- Remove detailed query timing logs from NodeClient
- Tests now pass with ClickHouse 25.10 (latest) without workarounds

Author: ShimonSte

clickhouse-core-it/src/test/scala/com/clickhouse/spark/HashSuite.scala

@@ -64,14 +64,8 @@ abstract class HashSuite extends AnyFunSuite with ClickHouseProvider with Loggin
     (testElement.combinations(1) ++ testElement.combinations(2) ++ testElement.combinations(3)).toArray
 
   test("CityHash64 Java implementation") {
-    log.info(s"[HashSuite] Starting CityHash64 test with ${testInputs.length} test inputs")
     withNodeClient() { client =>
-      var queryCount = 0
       testInputs.foreach { testInput =>
-        queryCount += 1
-        if (queryCount % 10 == 0) {
-          log.info(s"[HashSuite] CityHash64: Completed $queryCount/${testInputs.length} queries")
-        }
         val clickhouseInputExpr = testInput.mkString("'", "', '", "'")
         testHash(
           client,
@@ -81,7 +75,6 @@ abstract class HashSuite extends AnyFunSuite with ClickHouseProvider with Loggin
           clickhouseInputExpr
         )
       }
-      log.info(s"[HashSuite] CityHash64 test completed: $queryCount queries executed")
     }
   }
 

clickhouse-core/src/main/scala/com/clickhouse/spark/client/NodeClient.scala

@@ -199,27 +199,16 @@ class NodeClient(val nodeSpec: NodeSpec) extends AutoCloseable with Logging {
     settings: Map[String, String]
   ): Either[CHException, SimpleOutput[OUT]] = {
     val queryId = nextQueryId()
-    val startTime = System.currentTimeMillis()
-    log.info(s"[NodeClient] Starting query $queryId to ${nodeSpec.host}:${nodeSpec.port}")
     onExecuteQuery(queryId, sql)
     val querySettings: QuerySettings = new QuerySettings()
     val clickHouseFormat = ClickHouseFormat.valueOf(outputFormat)
     querySettings.setFormat(clickHouseFormat)
     querySettings.setQueryId(queryId)
     settings.foreach { case (k, v) => querySettings.setOption(k, v) }
     Try(clientV2.query(sql, querySettings).get(timeout, TimeUnit.MILLISECONDS)) match {
-      case Success(response: QueryResponse) =>
-        val duration = System.currentTimeMillis() - startTime
-        log.info(s"[NodeClient] Query $queryId completed successfully in ${duration}ms")
-        Right(deserializer(response.getInputStream))
-      case Failure(se: ServerException) =>
-        val duration = System.currentTimeMillis() - startTime
-        log.error(s"[NodeClient] Query $queryId failed with ServerException after ${duration}ms: ${se.getMessage}")
-        Left(CHServerException(se.getCode, se.getMessage, Some(nodeSpec), Some(se)))
-      case Failure(ex: Exception) =>
-        val duration = System.currentTimeMillis() - startTime
-        log.error(s"[NodeClient] Query $queryId failed with ${ex.getClass.getSimpleName} after ${duration}ms: ${ex.getMessage}")
-        Left(CHClientException(ex.getMessage, Some(nodeSpec), Some(ex)))
+      case Success(response: QueryResponse) => Right(deserializer(response.getInputStream))
+      case Failure(se: ServerException) => Left(CHServerException(se.getCode, se.getMessage, Some(nodeSpec), Some(se)))
+      case Failure(ex: Exception) => Left(CHClientException(ex.getMessage, Some(nodeSpec), Some(ex)))
     }
   }