У меня есть мастер Spark, и рабочие процессы работают в minikube
Код: Выделить всё
PS C:\Users\dlrla\workspace\bigdata\k8> kubectl get service -n spark
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
spark-master LoadBalancer 10.101.28.138 127.0.0.1 7077:31145/TCP,8080:31592/TCP 14h
PS C:\Users\dlrla\workspace\bigdata\k8> kubectl get deployments -n spark
NAME READY UP-TO-DATE AVAILABLE AGE
spark-master 1/1 1 1 126m
spark-worker 2/2 2 2 126m
Код: Выделить всё
spark = SparkSession.builder \
.appName("Pyspark example") \
.master("spark://127.0.0.1:7077") \
.getOrCreate()
# Sample data
data = [("Alice", 28), ("Bob", 35), ("Catherine", 25)]
columns = ["Name", "Age"]
# Create a DataFrame
df = spark.createDataFrame(data, columns)
# Show the DataFrame
df.show()
# Perform basic transformations
df.filter(df.Age > 30).show()
Код: Выделить всё
C:\Users\dlrla\workspace\python\spark-test\pythonProject\venv\Scripts\python.exe C:\Users\dlrla\workspace\python\spark-test\pythonProject\main.py
The system cannot find the path specified.
Кроме того, я только что проверил искровую отправку
Код: Выделить всё
(venv) PS C:\Users\dlrla\workspace\python\spark-test\pythonProject> spark-submit --version
PythonThe system cannot find the path specified.
Failed to find Spark jars directory.
You need to build Spark before running this program.
Подробнее здесь: https://stackoverflow.com/questions/793 ... n-minikube
Мобильная версия