We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7cb0459 commit 598cacaCopy full SHA for 598caca
docs/source/user_guide/apachespark/quickstart.rst
@@ -24,16 +24,16 @@ followed by the spark version, 3.2.1.
24
with tempfile.TemporaryDirectory() as td:
25
with open(os.path.join(td, "script.py"), "w") as f:
26
f.write(
27
- """
28
- import pyspark
+ """
+ import pyspark
29
30
- def main():
31
- print("Hello World")
32
- print("Spark version is", pyspark.__version__)
+ def main():
+ print("Hello World")
+ print("Spark version is", pyspark.__version__)
33
34
- if __name__ == "__main__":
35
- main()
36
+ if __name__ == "__main__":
+ main()
37
)
38
39
name = f"dataflow-app-{str(uuid4())}"
0 commit comments