mattcasters commented on PR #8951: URL: https://github.com/apache/hop/pull/8951#issuecomment-6214566962
The original issue seems solved but I can't run the Spark pipeline on my corporate laptop to verify. ``` 2026/10/16 13:28:33 [Basic] spark-test - Prepared native Spark pipeline engine with run configuration 'spark-local' (master=local[*]) 2026/10/16 13:28:34 [Basic] spark-test - HADOOP_HOME and hadoop.home.dir are unset. Local Spark paths will keep the permissions of this process instead of calling winutils. 2026/10/16 13:28:35 [Basic] spark-test - Created SparkSession version=4.1.3 master=local[*] (owned) 2026/10/16 13:28:59 [Error] spark-test - Error executing Spark pipeline 2026/10/16 13:28:59 [Error] spark-test - org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 2.0 failed 1 times, most recent failure: Lost task 0.0 in stage 2.0 (TID 1) (10.203.181.5 executor driver): org.apache.spark.executor.RemoteClassLoaderError: org.apache.spark.sql.catalyst.expressions.Object 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.findClass(ExecutorClassLoader.scala:117) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:593) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:580) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.ParentClassLoader.loadClass(ParentClassLoader.java:40) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:526) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassLoaderIClassLoader.findIClass(ClassLoaderIClassLoader.java:75) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClassLoader.loadIClass(IClassLoader.java:317) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.findTypeByName(UnitCompiler.java:8895) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getRawReferenceType(UnitCompiler.java:7065) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6974) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6855) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6826) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$14800(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6724) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$ReferenceType.accept(Java.java:4289) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getRawType(UnitCompiler.java:6717) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7189) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$14600(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitArrayType(UnitCompiler.java:6722) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitArrayType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$ArrayType.accept(Java.java:4382) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getRawType(UnitCompiler.java:6717) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$1300(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$41.getParameterTypes2(UnitCompiler.java:10775) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass$IInvocable.getParameterTypes(IClass.java:903) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass$IMethod.getDescriptor2(IClass.java:1170) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass$IInvocable.getDescriptor(IClass.java:926) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass.getIMethods(IClass.java:270) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass.getIMethods(IClass.java:259) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:502) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:442) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:422) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:418) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1688) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:418) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:392) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$000(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:363) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:361) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$CompilationUnit.accept(Java.java:371) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:361) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:264) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:294) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:288) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:267) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:82) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.doCompile(CodeGenerator.scala:1549) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.$anonfun$cache$1(CodeGenerator.scala:1638) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.NonFateSharingCache$$anon$1.load(NonFateSharingCache.scala:68) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3551) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$Segment.loadSync(LocalCache.java:2302) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2177) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$Segment.get(LocalCache.java:2068) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache.get(LocalCache.java:3986) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache.getOrLoad(LocalCache.java:4007) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4946) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.NonFateSharingLoadingCache.$anonfun$get$2(NonFateSharingCache.scala:108) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.KeyLock.withLock(KeyLock.scala:64) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.NonFateSharingLoadingCache.get(NonFateSharingCache.scala:108) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.compile(CodeGenerator.scala:1490) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.GenerateSafeProjection$.create(GenerateSafeProjection.scala:205) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.GenerateSafeProjection$.create(GenerateSafeProjection.scala:39) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator.generate(CodeGenerator.scala:1415) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator.generate(CodeGenerator.scala:1412) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.DeserializeToObjectExec.$anonfun$doExecute$1(objects.scala:95) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.DeserializeToObjectExec.$anonfun$doExecute$1$adapted(objects.scala:94) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.$anonfun$mapPartitionsWithIndexInternal$2(RDD.scala:888) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.$anonfun$mapPartitionsWithIndexInternal$2$adapted(RDD.scala:888) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.SQLExecutionRDD.compute(SQLExecutionRDD.scala:55) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.SQLExecutionRDD.compute(SQLExecutionRDD.scala:55) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.SQLExecutionRDD.compute(SQLExecutionRDD.scala:55) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:107) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:54) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.TaskContext.runTaskWithListeners(TaskContext.scala:180) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.Task.run(Task.scala:147) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$4(Executor.scala:873) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally(SparkErrorUtils.scala:86) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally$(SparkErrorUtils.scala:83) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:97) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:876) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.Thread.run(Thread.java:1583) 2026/10/16 13:28:59 [Error] spark-test - Caused by: java.io.IOException: Failed to connect to /10.203.181.5:58422 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:304) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:224) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rpc.netty.NettyRpcEnv.downloadClient(NettyRpcEnv.scala:406) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rpc.netty.NettyRpcEnv.$anonfun$openChannel$4(NettyRpcEnv.scala:370) 2026/10/16 13:28:59 [Error] spark-test - at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.Utils$.tryWithSafeFinallyAndFailureCallbacks(Utils.scala:1337) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rpc.netty.NettyRpcEnv.openChannel(NettyRpcEnv.scala:369) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.getClassFileInputStreamFromSparkRPC(ExecutorClassLoader.scala:132) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.$anonfun$fetchFn$1(ExecutorClassLoader.scala:63) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.findClassLocally(ExecutorClassLoader.scala:173) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.findClass(ExecutorClassLoader.scala:110) 2026/10/16 13:28:59 [Error] spark-test - ... 140 more 2026/10/16 13:28:59 [Error] spark-test - Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection timed out: getsockopt: /10.203.181.5:58422 2026/10/16 13:28:59 [Error] spark-test - Caused by: java.net.ConnectException: Connection timed out: getsockopt 2026/10/16 13:28:59 [Error] spark-test - at java.base/sun.nio.ch.Net.pollConnect(Native Method) 2026/10/16 13:28:59 [Error] spark-test - at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:694) 2026/10/16 13:28:59 [Error] spark-test - at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:330) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:384) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.handle(AbstractNioChannel.java:432) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler$DefaultNioRegistration.handle(NioIoHandler.java:388) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.processSelectedKey(NioIoHandler.java:596) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.processSelectedKeysOptimized(NioIoHandler.java:571) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.processSelectedKeys(NioIoHandler.java:512) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.run(NioIoHandler.java:484) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.Thread.run(Thread.java:1583) 2026/10/16 13:28:59 [Error] spark-test - Driver stacktrace: 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$3(DAGScheduler.scala:3122) 2026/10/16 13:28:59 [Error] spark-test - at scala.Option.getOrElse(Option.scala:201) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$2(DAGScheduler.scala:3122) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$2$adapted(DAGScheduler.scala:3114) 2026/10/16 13:28:59 [Error] spark-test - at scala.collection.immutable.List.foreach(List.scala:323) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:3114) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.$anonfun$handleTaskSetFailed$1(DAGScheduler.scala:1303) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.$anonfun$handleTaskSetFailed$1$adapted(DAGScheduler.scala:1303) 2026/10/16 13:28:59 [Error] spark-test - at scala.Option.foreach(Option.scala:437) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGScheduler.handleTaskSetFailed(DAGScheduler.scala:1303) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:3397) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3328) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3317) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:50) 2026/10/16 13:28:59 [Error] spark-test - Caused by: org.apache.spark.executor.RemoteClassLoaderError: org.apache.spark.sql.catalyst.expressions.Object 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.findClass(ExecutorClassLoader.scala:117) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:593) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:580) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.ParentClassLoader.loadClass(ParentClassLoader.java:40) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:526) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassLoaderIClassLoader.findIClass(ClassLoaderIClassLoader.java:75) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClassLoader.loadIClass(IClassLoader.java:317) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.findTypeByName(UnitCompiler.java:8895) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getRawReferenceType(UnitCompiler.java:7065) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6974) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6855) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6826) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$14800(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6724) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$ReferenceType.accept(Java.java:4289) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getRawType(UnitCompiler.java:6717) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7189) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$14600(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitArrayType(UnitCompiler.java:6722) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$24.visitArrayType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$ArrayType.accept(Java.java:4382) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6721) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.getRawType(UnitCompiler.java:6717) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$1300(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$41.getParameterTypes2(UnitCompiler.java:10775) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass$IInvocable.getParameterTypes(IClass.java:903) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass$IMethod.getDescriptor2(IClass.java:1170) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass$IInvocable.getDescriptor(IClass.java:926) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass.getIMethods(IClass.java:270) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.IClass.getIMethods(IClass.java:259) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:502) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:442) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:422) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:418) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1688) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:418) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:392) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.access$000(UnitCompiler.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:363) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:361) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.Java$CompilationUnit.accept(Java.java:371) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:361) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:264) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:294) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:288) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.janino.ClassBodyEvaluator.cook(ClassBodyEvaluator.java:267) 2026/10/16 13:28:59 [Error] spark-test - at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:82) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.doCompile(CodeGenerator.scala:1549) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.$anonfun$cache$1(CodeGenerator.scala:1638) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.NonFateSharingCache$$anon$1.load(NonFateSharingCache.scala:68) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3551) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$Segment.loadSync(LocalCache.java:2302) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2177) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$Segment.get(LocalCache.java:2068) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache.get(LocalCache.java:3986) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache.getOrLoad(LocalCache.java:4007) 2026/10/16 13:28:59 [Error] spark-test - at org.sparkproject.guava.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4946) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.NonFateSharingLoadingCache.$anonfun$get$2(NonFateSharingCache.scala:108) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.KeyLock.withLock(KeyLock.scala:64) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.NonFateSharingLoadingCache.get(NonFateSharingCache.scala:108) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator$.compile(CodeGenerator.scala:1490) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.GenerateSafeProjection$.create(GenerateSafeProjection.scala:205) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.GenerateSafeProjection$.create(GenerateSafeProjection.scala:39) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator.generate(CodeGenerator.scala:1415) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.catalyst.expressions.codegen.CodeGenerator.generate(CodeGenerator.scala:1412) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.DeserializeToObjectExec.$anonfun$doExecute$1(objects.scala:95) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.DeserializeToObjectExec.$anonfun$doExecute$1$adapted(objects.scala:94) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.$anonfun$mapPartitionsWithIndexInternal$2(RDD.scala:888) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.$anonfun$mapPartitionsWithIndexInternal$2$adapted(RDD.scala:888) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.SQLExecutionRDD.compute(SQLExecutionRDD.scala:55) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.SQLExecutionRDD.compute(SQLExecutionRDD.scala:55) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.sql.execution.SQLExecutionRDD.compute(SQLExecutionRDD.scala:55) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:52) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:374) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rdd.RDD.iterator(RDD.scala:338) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:107) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:54) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.TaskContext.runTaskWithListeners(TaskContext.scala:180) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.scheduler.Task.run(Task.scala:147) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$4(Executor.scala:873) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally(SparkErrorUtils.scala:86) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally$(SparkErrorUtils.scala:83) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:97) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:876) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.Thread.run(Thread.java:1583) 2026/10/16 13:28:59 [Error] spark-test - Caused by: java.io.IOException: Failed to connect to /10.203.181.5:58422 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:304) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:224) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.network.client.TransportClientFactory.createClient(TransportClientFactory.java:236) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rpc.netty.NettyRpcEnv.downloadClient(NettyRpcEnv.scala:406) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rpc.netty.NettyRpcEnv.$anonfun$openChannel$4(NettyRpcEnv.scala:370) 2026/10/16 13:28:59 [Error] spark-test - at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.util.Utils$.tryWithSafeFinallyAndFailureCallbacks(Utils.scala:1337) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.rpc.netty.NettyRpcEnv.openChannel(NettyRpcEnv.scala:369) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.getClassFileInputStreamFromSparkRPC(ExecutorClassLoader.scala:132) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.$anonfun$fetchFn$1(ExecutorClassLoader.scala:63) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.findClassLocally(ExecutorClassLoader.scala:173) 2026/10/16 13:28:59 [Error] spark-test - at org.apache.spark.executor.ExecutorClassLoader.findClass(ExecutorClassLoader.scala:110) 2026/10/16 13:28:59 [Error] spark-test - ... 140 more 2026/10/16 13:28:59 [Error] spark-test - Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection timed out: getsockopt: /10.203.181.5:58422 2026/10/16 13:28:59 [Error] spark-test - Caused by: java.net.ConnectException: Connection timed out: getsockopt 2026/10/16 13:28:59 [Error] spark-test - at java.base/sun.nio.ch.Net.pollConnect(Native Method) 2026/10/16 13:28:59 [Error] spark-test - at java.base/sun.nio.ch.Net.pollConnectNow(Net.java:694) 2026/10/16 13:28:59 [Error] spark-test - at java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:973) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:330) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:384) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.handle(AbstractNioChannel.java:432) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler$DefaultNioRegistration.handle(NioIoHandler.java:388) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.processSelectedKey(NioIoHandler.java:596) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.processSelectedKeysOptimized(NioIoHandler.java:571) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.processSelectedKeys(NioIoHandler.java:512) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.nio.NioIoHandler.run(NioIoHandler.java:484) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1204) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 2026/10/16 13:28:59 [Error] spark-test - at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) 2026/10/16 13:28:59 [Error] spark-test - at java.base/java.lang.Thread.run(Thread.java:1583) ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
