我使用以下代码将一些数据写入sequencefile格式文件。当程序运行一段时间后，我通过eclipse控制台上的红色按钮中断程序。但是，当我检查hdfs上的数据文件时，序列文件的大小是零。而且也不能用'hadoop fs-text filename'命令查看文件。当我使用sequencefile.reader读取之前创建的文件时，遇到了“exception in thread”main“java.io.eofexception”异常。在这种情况下，怎么办？我的开发环境是eclipse3.7（在Windows7上）和hadoop cluster（hadoop版本1.0.3）在centos 6上。
类序列扩展线程{

private String uri = "hdfs://172.20.11.60:9000";
private String filePath = "/user/hadoop/input/";
private String fileName = "Sequence-01.seq";
public SequenceFile.Writer writer;
private static int cnt = 0;

private void init() {
    Configuration conf = new Configuration();
    try {
        FileSystem fs = FileSystem.get(URI.create(uri), conf);
        writer = SequenceFile.createWriter(fs, conf, new Path(filePath
                + fileName), LongWritable.class, Text.class);
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

public Sequence() {
    init();
}

@Override
public void run(){
    while(true){
        try {
            writer.append(new LongWritable(100), new Text("hello,world"));
            cnt++;
            if(cnt%100 == 0){
                System.out.println("flush current data to file system");
                writer.syncFs();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            System.out.println("append data error");
            e.printStackTrace();
        }

        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            System.out.println("thread interupted");
            e.printStackTrace();
        }
    }
}

}
公共类testsequencefile{

/**
 * @param args
 */
public static void main(String[] args) {
    // TODO Auto-generated method stub

    new Sequence().start();
}

}