Hi, I am upgrading to 0.20 from 0.18, and right now the setup() gets called, but the map() does not.
The log indicates that an input record was found - but it is not processed. 10/09/19 23:56:21 INFO mapred.TaskRunner: Task:attempt_local_0001_r_000000_0 is done. And is in the process of commiting 10/09/19 23:56:21 INFO mapred.LocalJobRunner: 10/09/19 23:56:21 INFO mapred.TaskRunner: Task attempt_local_0001_r_000000_0 is allowed to commit now 10/09/19 23:56:21 INFO mapred.JobClient: map 100% reduce 0% 10/09/19 23:56:21 INFO output.FileOutputCommitter: Saved output of task 'attempt_local_0001_r_000000_0' to hdfs://localhost:9000/scala/p1/output 10/09/19 23:56:21 INFO mapred.LocalJobRunner: reduce > reduce 10/09/19 23:56:21 INFO mapred.TaskRunner: Task 'attempt_local_0001_r_000000_0' done. 10/09/19 23:56:22 INFO mapred.JobClient: map 100% reduce 100% 10/09/19 23:56:22 INFO mapred.JobClient: Job complete: job_local_0001 10/09/19 23:56:22 INFO mapred.JobClient: Counters: 14 10/09/19 23:56:22 INFO mapred.JobClient: FileSystemCounters 10/09/19 23:56:22 INFO mapred.JobClient: FILE_BYTES_READ=35600 10/09/19 23:56:22 INFO mapred.JobClient: HDFS_BYTES_READ=10820 10/09/19 23:56:22 INFO mapred.JobClient: FILE_BYTES_WRITTEN=71798 10/09/19 23:56:22 INFO mapred.JobClient: HDFS_BYTES_WRITTEN=421 10/09/19 23:56:22 INFO mapred.JobClient: Map-Reduce Framework 10/09/19 23:56:22 INFO mapred.JobClient: Reduce input groups=1 10/09/19 23:56:22 INFO mapred.JobClient: Combine output records=0 10/09/19 23:56:22 INFO mapred.JobClient: Map input records=1 10/09/19 23:56:22 INFO mapred.JobClient: Reduce shuffle bytes=0 10/09/19 23:56:22 INFO mapred.JobClient: Reduce output records=1 10/09/19 23:56:22 INFO mapred.JobClient: Spilled Records=2 10/09/19 23:56:22 INFO mapred.JobClient: Map output bytes=14 10/09/19 23:56:22 INFO mapred.JobClient: Combine input records=0 10/09/19 23:56:22 INFO mapred.JobClient: Map output records=1 10/09/19 23:56:22 INFO mapred.JobClient: Reduce input records=1 Thank you for advice. Sincerely, Mark
