Task io.fabric8.kubernetes.client.utils.internal.SerialExecutor$$Lambda$580/2121413029@528e7413 rejected from java.util.concurrent.ThreadPoolExecutor@1644434b[Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 320]

Run / Run Spark on Kubernetes Integration test

Task io.fabric8.kubernetes.client.utils.internal.SerialExecutor$$Lambda$580/2121413029@14e8a3bb rejected from java.util.concurrent.ThreadPoolExecutor@1644434b[Shutting down, pool size = 2, active threads = 2, queued tasks = 0, completed tasks = 319]

Run / Run Spark on Kubernetes Integration test

Set() did not contain "decomtest-4754458a90c4923e-exec-1".

Run / Run Spark on Kubernetes Integration test

Set() did not contain "decomtest-613f6f8a90c5dd7e-exec-1".

Run / Run Spark on Kubernetes Integration test

Set() did not contain "decomtest-625a488a90ca59e2-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-df87b6bdd8e244dda89b2b86b88b1f12-driver, retryAfterSeconds=null, uid=null, additionalProperties={}), kind=Status, message=pods "spark-test-app-df87b6bdd8e244dda89b2b86b88b1f12-driver" not found, metadata=ListMeta(_continue=null, remainingItemCount=null, resourceVersion=null, selfLink=null, additionalProperties={}), reason=NotFound, status=Failure, additionalProperties={})..

python/pyspark/sql/tests/connect/test_parity_arrow_python_udf.py.test_named_arguments_negative: python/pyspark/sql/tests/connect/test_parity_arrow_python_udf.py#L1

"test_udf got an unexpected keyword argument 'c'" does not match " An exception was thrown from the Python worker. Please see the stack trace below. Traceback (most recent call last): File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 1321, in main process() File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 1313, in process serializer.dump_stream(out_iter, outfile) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/sql/pandas/serializers.py", line 470, in dump_stream return ArrowStreamSerializer.dump_stream(self, init_stream_yield_batches(), stream) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/sql/pandas/serializers.py", line 100, in dump_stream for batch in iterator: File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/sql/pandas/serializers.py", line 463, in init_stream_yield_batches for series in iterator: File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 1221, in mapper result = tuple(f(*[a[o] for o in arg_offsets]) for arg_offsets, f in udfs) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 1221, in <genexpr> result = tuple(f(*[a[o] for o in arg_offsets]) for arg_offsets, f in udfs) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 166, in <lambda> lambda *a: (verify_result_length(evaluate(*a), len(a[0])), arrow_return_type), File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/util.py", line 87, in wrapper return f(*args, **kwargs) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 151, in evaluate return pd.Series([result_func(func(*row)) for row in zip(*args)]) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 151, in <listcomp> return pd.Series([result_func(func(*row)) for row in zip(*args)]) File "/__w/apache-spark/apache-spark/python/lib/pyspark.zip/pyspark/worker.py", line 548, in func return f(**dict(zip(keys, args))) TypeError: test_udf() got an unexpected keyword..."

Run / Build modules: hive - other tests