我在hadoop中执行压缩程序时遇到了一个问题。我正在尝试的代码如下:
public class StreamCompressor {
public static void main(String[] args) throws Exception {
String codecClassname = args[0];
Class<?> codecClass = Class.forName(codecClassname);
Configuration conf = new Configuration();
CompressionCodec codec = (CompressionCodec);
ReflectionUtils.newInstance(codecClass, conf);
CompressionOutputStream out = codec.createOutputStream(System.out);
IOUtils.copyBytes(System.in, out, 4096, false);
out.finish();
}
}
执行此代码时,它不运行;它只显示一个闪烁的光标。这是一个屏幕截图。
发出运行指令后卡住了。
暂无答案!
目前还没有任何答案,快来回答吧!