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 6e45bc9 commit da85c84Copy full SHA for da85c84
composer/workflows/hadoop_tutorial.py
@@ -42,7 +42,8 @@
42
'file:///usr/lib/hadoop-mapreduce/hadoop-mapreduce-examples.jar'
43
)
44
# Arguments to pass to Cloud Dataproc job.
45
-wordcount_args = ['wordcount', 'gs://pub/shakespeare/rose.txt', output_file]
+input_file = 'gs://pub/shakespeare/rose.txt'
46
+wordcount_args = ['wordcount', input_file, output_file]
47
48
yesterday = datetime.datetime.combine(
49
datetime.datetime.today() - datetime.timedelta(1),
0 commit comments