hadoop2.2.0编译wordcount程序报错,请大侠帮忙

时间:2022-09-24 23:21:01
环境:
centos 6.0
hadoop2.2.0

$ javac -classpath $HADOOP_HOME/share/hadoop/common/hado
op-common-2.2.0.jar:$HADOOP_HOME/share/hadoop/mapreduce/hadoop-mapreduce-client-core-2.2.0
.jar:$HADOOP_HOME/share/hadoop/common/lib/commons-cli-1.2.jar -d wordcount_classes WordCount.java
Note: WordCount.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.


WordCount.java如下
————————————————————————————————————————————————————————————————————————————————————————
//: c11:WordCount.java
// From 'Thinking in Java, 2nd ed.' by Bruce Eckel
// www.BruceEckel.com. See copyright notice in CopyRight.txt.
// Counts words from a file, outputs
// results in sorted form.
import java.io.*;
import java.util.*;

class Counter {
  private int i = 1;
  int read() { return i; }
  void increment() { i++; }
}

public class WordCount {
  private FileReader file;
  private StreamTokenizer st;
  // A TreeMap keeps keys in sorted order:
  private TreeMap counts = new TreeMap();
  WordCount(String filename)
    throws FileNotFoundException {
    try {
      file = new FileReader(filename);
      st = new StreamTokenizer(
        new BufferedReader(file));
      st.ordinaryChar('.');
      st.ordinaryChar('-');
    } catch(FileNotFoundException e) {
      System.out.println(
        "Could not open " + filename);
      throw e;
    }
  }
  void cleanup() {
    try {
      file.close();
    } catch(IOException e) {
      System.out.println(
        "file.close() unsuccessful");
    }
  }
  void countWords() {
    try {
      while(st.nextToken() !=
        StreamTokenizer.TT_EOF) {
        String s;
        switch(st.ttype) {
          case StreamTokenizer.TT_EOL:
            s = new String("EOL");
            break;
          case StreamTokenizer.TT_NUMBER:
            s = Double.toString(st.nval);
            break;
          case StreamTokenizer.TT_WORD:
            s = st.sval; // Already a String
            break;
          default: // single character in ttype
            s = String.valueOf((char)st.ttype);
        }
        if(counts.containsKey(s))
          ((Counter)counts.get(s)).increment();
        else
          counts.put(s, new Counter());
      }
    } catch(IOException e) {
      System.out.println(
        "st.nextToken() unsuccessful");
    }
  }
  Collection values() {
    return counts.values();
  }
  Set keySet() { return counts.keySet(); }
  Counter getCounter(String s) {
    return (Counter)counts.get(s);
  }
  public static void main(String[] args) {
    try {
      WordCount wc =
        new WordCount(args[0]);
      wc.countWords();
      Iterator keys = wc.keySet().iterator();
      while(keys.hasNext()) {
        String key = (String)keys.next();
        System.out.println(key + ": "
                 + wc.getCounter(key).read());
      }
      wc.cleanup();
    } catch(Exception e) {
      e.printStackTrace();
    }
  }
} ///:~

6 个解决方案

#1


Note: WordCount.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
这两行错误应该怎么解决?

#2


我自己发现问题出在
if(counts.containsKey(s))
          ((Counter)counts.get(s)).increment();
        else
          counts.put(s, new Counter());
这段代码,如果没有这段代码就不会有Note的信息了
请问这段代码有什么问题吗

#3


LZ
这个问题和你前面的问题好像重复了

#4


引用 3 楼 tntzbzc 的回复:
LZ
这个问题和你前面的问题好像重复了

没有重复,之前那个是执行时的错,这个是编译时的问题

#5


没人回答吗,结贴算了

#6


该回复于2014-02-23 20:22:53被版主删除

#1


Note: WordCount.java uses unchecked or unsafe operations.
Note: Recompile with -Xlint:unchecked for details.
这两行错误应该怎么解决?

#2


我自己发现问题出在
if(counts.containsKey(s))
          ((Counter)counts.get(s)).increment();
        else
          counts.put(s, new Counter());
这段代码,如果没有这段代码就不会有Note的信息了
请问这段代码有什么问题吗

#3


LZ
这个问题和你前面的问题好像重复了

#4


引用 3 楼 tntzbzc 的回复:
LZ
这个问题和你前面的问题好像重复了

没有重复,之前那个是执行时的错,这个是编译时的问题

#5


没人回答吗,结贴算了

#6


该回复于2014-02-23 20:22:53被版主删除