Permalink
Browse files

modified files

  • Loading branch information...
1 parent 88ac97d commit fcc4d8b49244091e453b74da317ccbb30de3351b @kykamath committed Oct 11, 2012
Showing with 4 additions and 2 deletions.
  1. +4 −2 hashtag_propagation_in_groups/analysis.py
@@ -39,8 +39,10 @@ def run_job(mr_class, output_file, input_files_start_time, input_files_end_time)
@staticmethod
def run_job_on_hashtags_in_dfs(mr_class, output_file):
job_conf={'mapred.reduce.tasks':500, 'mapred.task.timeout': 86400000}
- print 'Running map reduce with the following params:', pprint(PARAMS_DICT)
- print 'Hadoop job conf:', pprint(job_conf)
+ print 'Running map reduce with the following params:'
+ pprint(PARAMS_DICT)
+ print 'Hadoop job conf:'
+ pprint(job_conf)
runMRJob(mr_class, output_file, [f_hdfs_hashtags], jobconf=job_conf)
FileIO.writeToFileAsJson(PARAMS_DICT, output_file)
@staticmethod

0 comments on commit fcc4d8b

Please sign in to comment.