这是一个Task

public static void main(String[] args) throws IOException {
EntityLinkWordMegerBolt csb = new EntityLinkWordMegerBolt();
FindIterable<Document> documents = BUnit.readInputUnitStream();
File file =new File("D:\\Projects\\logs\\output_ELWMB.txt");
        file.createNewFile();
        FileOutputStream fileOutputStream = new FileOutputStream(f);
        PrintStream printStream = new PrintStream(fileOutputStream); 
        System.setErr(printStream);
      if(documents!=null){
Map stormConf = BUnit.getStormConfig();
csb.prepare(stormConf, null);
int i = 0;
for(Document document:documents){
//System.err.println(document);
UnitStreamTupleImpl tuple = new UnitStreamTupleImpl(JSONObject.parseObject(document.toJson()));
csb.execute(tuple, new UnitStreamBaiscOutputCollectorImpl(null));
i++;
}
System.out.println("over"+i);
}
}

过程中遇到了eclipse报错，无法启动：

java.lang.OutOfMemoryError: java heap space

解决办法：找到eclipse安装目录下的：eclipse.ini文件

修改：

-Xms512m
-Xmx2048m

问题解决，大小可根据自己需要来定。