The codec should be associated to the Hadoop configuration. In Scala: val hadoopConfig = new org.apache.hadoop.conf.Configuration() val hdfs = org.apache.hadoop.fs.FileSystem.get (hadoopConfig) val bzCodec = new org.apache.hadoop.io.compress.BZip2Codec() bzCodec.setConf (hadoopConfig) val outputFile = hdfs.create (new org.apache.hadoop.fs.Path (uriDest)) val outputStream = bzCodec.createOutputStream (outputFile) ... View more

Okay, that makes sense. And I just checked and on my mac I was actually doing the command: hadoop com/thomp/io/FileSystemCat /HadoopPrac/Data/sample.txt which also worked. Thanks again! ... View more

@pankaj kushwaha Making sure all the services are stopped and then doing a shutdown command from inside the host VM is your best bet at making sure nothing gets broken. ... View more