Task io.fabric8.kubernetes.client.utils.internal.SerialExecutor$$Lambda$679/0x00007fe1a45c1b58@35906bc0 rejected from java.util.concurrent.ThreadPoolExecutor@1f4e28fa[Shutting down, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 306]

Run / Run Spark on Kubernetes Integration test

sleep interrupted

Run / Run Spark on Kubernetes Integration test

Task io.fabric8.kubernetes.client.utils.internal.SerialExecutor$$Lambda$679/0x00007fe1a45c1b58@4dba5375 rejected from java.util.concurrent.ThreadPoolExecutor@1f4e28fa[Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 307]

Run / Run Spark on Kubernetes Integration test

HashSet() did not contain "decomtest-27ba3a8b4afcb840-exec-1".

Run / Run Spark on Kubernetes Integration test

HashSet() did not contain "decomtest-6a53db8b4afdbe04-exec-1".

Run / Run Spark on Kubernetes Integration test

HashSet() did not contain "decomtest-c70ac08b4b019401-exec-1".

Run / Run Spark on Kubernetes Integration test

Status(apiVersion=v1, code=404, details=StatusDetails(causes=[], group=null, kind=pods, name=spark-test-app-0b79e5eecb2648a497b27c5cf9da5e9d-driver, retryAfterSeconds=null, uid=null, additionalProperties={}), kind=Status, message=pods "spark-test-app-0b79e5eecb2648a497b27c5cf9da5e9d-driver" not found, metadata=ListMeta(_continue=null, remainingItemCount=null, resourceVersion=null, selfLink=null, additionalProperties={}), reason=NotFound, status=Failure, additionalProperties={})..

Run / Build modules: streaming, sql-kafka-0-10, streaming-kafka-0-10, mllib-local, mllib, yarn, kubernetes, hadoop-cloud, spark-ganglia-lgpl, connect, protobuf

The hosted runner: GitHub Actions 11 lost communication with the server. Anything in your workflow that terminates the runner process, starves it for CPU/Memory, or blocks its network access can cause this error.

Run / Build modules: core, unsafe, kvstore, avro, network-common, network-shuffle, repl, launcher, examples, sketch, graphx

The job running on runner GitHub Actions 10 has exceeded the maximum execution time of 300 minutes.

Run / Build modules: core, unsafe, kvstore, avro, network-common, network-shuffle, repl, launcher, examples, sketch, graphx

The operation was canceled.

BlockManagerDecommissionIntegrationSuite.SPARK-32850: BlockManager decommission should respect the configuration (enabled=false): BlockManagerDecommissionIntegrationSuite#L68

org.scalatest.exceptions.TestFailedDueToTimeoutException: The code passed to failAfter did not complete within 20 minutes.

BlockManagerDecommissionIntegrationSuite.SPARK-32850: BlockManager decommission should respect the configuration (enabled=true): BlockManagerDecommissionIntegrationSuite#L52

org.apache.spark.SparkException: Only one SparkContext should be running in this JVM (see SPARK-2243).The currently running SparkContext was created at: org.apache.spark.SparkContext.<init>(SparkContext.scala:88) org.apache.spark.storage.BlockManagerDecommissionIntegrationSuite.$anonfun$new$2(BlockManagerDecommissionIntegrationSuite.scala:52) scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18) org.scalatest.enablers.Timed$$anon$1.timeoutAfter(Timed.scala:127) org.scalatest.concurrent.TimeLimits$.failAfterImpl(TimeLimits.scala:282) org.scalatest.concurrent.TimeLimits.failAfter(TimeLimits.scala:231) org.scalatest.concurrent.TimeLimits.failAfter$(TimeLimits.scala:230) org.apache.spark.SparkFunSuite.failAfter(SparkFunSuite.scala:69) org.apache.spark.SparkFunSuite.$anonfun$test$2(SparkFunSuite.scala:155) org.scalatest.OutcomeOf.outcomeOf(OutcomeOf.scala:85) org.scalatest.OutcomeOf.outcomeOf$(OutcomeOf.scala:83) org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104) org.scalatest.Transformer.apply(Transformer.scala:22) org.scalatest.Transformer.apply(Transformer.scala:20) org.scalatest.funsuite.AnyFunSuiteLike$$anon$1.apply(AnyFunSuiteLike.scala:226) org.apache.spark.SparkFunSuite.withFixture(SparkFunSuite.scala:227) org.scalatest.funsuite.AnyFunSuiteLike.invokeWithFixture$1(AnyFunSuiteLike.scala:224) org.scalatest.funsuite.AnyFunSuiteLike.$anonfun$runTest$1(AnyFunSuiteLike.scala:236) org.scalatest.SuperEngine.runTestImpl(Engine.scala:306) org.scalatest.funsuite.AnyFunSuiteLike.runTest(AnyFunSuiteLike.scala:236)

BlockManagerDecommissionIntegrationSuite.verify that an already running task which is going to cache data succeeds on a decommissioned executor after task start: BlockManagerDecommissionIntegrationSuite#L86

BlockManagerDecommissionIntegrationSuite.verify that an already running task which is going to cache data succeeds on a decommissioned executor after one task ends but before job ends: BlockManagerDecommissionIntegrationSuite#L91

BlockManagerDecommissionIntegrationSuite.verify that shuffle blocks are migrated: BlockManagerDecommissionIntegrationSuite#L95

BlockManagerDecommissionIntegrationSuite.verify that both migrations can work at the same time: BlockManagerDecommissionIntegrationSuite#L99

BlockManagerDecommissionIntegrationSuite.SPARK-36782 not deadlock if MapOutput uses broadcast: BlockManagerDecommissionIntegrationSuite#L103

python/pyspark/sql/tests/pandas/test_pandas_grouped_map.py.test_apply_in_pandas_returning_incompatible_type (convert='string to double', convertToArrowArraySafely=True): python/pyspark/sql/tests/pandas/test_pandas_grouped_map.py#L1