java.lang.IllegalArgumentException: requirement failed: TransportClient has not yet been set.
Searched on Google with the first line of a JAVA stack trace?
We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.
Recommended solutions based on your search
Samebug tips
Delete the corrupted index files and on startup, Kafka server will rebuild it.
Solutions on the web
via Stack Overflow by zpz
, 1 year agovia Stack Overflow by rabejens
, 9 months agovia GitHub by tmckayus
, 1 year agovia GitHub by tmckayus
, 1 year agovia Stack Overflow by Ed Young
, 1 year agovia Stack Overflow by aichemzee
, 1 year agojava.lang.IllegalArgumentException: requirement failed: TransportClient has not yet been set.at scala.Predef$.require(Predef.scala:224)at org.apache.spark.rpc.netty.RpcOutboxMessage.onTimeout(Outbox.scala:70)at org.apache.spark.rpc.netty.NettyRpcEnv$$anonfun$ask$1.applyOrElse(NettyRpcEnv.scala:232)at org.apache.spark.rpc.netty.NettyRpcEnv$$anonfun$ask$1.applyOrElse(NettyRpcEnv.scala:231)at scala.concurrent.Future$$anonfun$onFailure$1.apply(Future.scala:138)at scala.concurrent.Future$$anonfun$onFailure$1.apply(Future.scala:136)at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32)at org.spark_project.guava.util.concurrent.MoreExecutors$SameThreadExecutorService.execute(MoreExecutors.java:293)at scala.concurrent.impl.ExecutionContextImpl$$anon$1.execute(ExecutionContextImpl.scala:136)at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40)at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:248)at scala.concurrent.Promise$class.tryFailure(Promise.scala:112)