Skip to content

Commit

Permalink
removing logger from an execution plan
Browse files Browse the repository at this point in the history
  • Loading branch information
Kier Petrov committed Jan 3, 2025
1 parent 8a15d74 commit 8b7d253
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package filodb.coordinator

import com.typesafe.scalalogging.StrictLogging
import io.grpc.Metadata
import io.grpc.stub.{MetadataUtils, StreamObserver}
import java.net.InetAddress
Expand Down Expand Up @@ -29,7 +28,7 @@ object GrpcPlanDispatcher {
Runtime.getRuntime.addShutdownHook(new Thread(() => channelMap.values.foreach(_.shutdown())))
}

case class GrpcPlanDispatcher(endpoint: String, requestTimeoutMs: Long) extends PlanDispatcher with StrictLogging {
case class GrpcPlanDispatcher(endpoint: String, requestTimeoutMs: Long) extends PlanDispatcher {

val clusterName = InetAddress.getLocalHost().getHostName()

Expand Down Expand Up @@ -67,8 +66,6 @@ case class GrpcPlanDispatcher(endpoint: String, requestTimeoutMs: Long) extends
val genericRemoteExec = plan.execPlan.asInstanceOf[GenericRemoteExec]
import filodb.coordinator.ProtoConverters._
val protoPlan = genericRemoteExec.execPlan.toExecPlanContainerProto
logger.debug(s"Query ${plan.execPlan.queryContext.queryId} proto plan size is ${protoPlan.toByteArray.length}B")
logger.debug(s"Query ${plan.execPlan.queryContext.queryId} exec plan ${genericRemoteExec.execPlan.printTree()}")
val queryContextProto = genericRemoteExec.execPlan.queryContext.toProto
val remoteExecPlan : RemoteExecPlan = RemoteExecPlan.newBuilder()
.setExecPlan(protoPlan)
Expand Down

0 comments on commit 8b7d253

Please sign in to comment.