Index: src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java
===================================================================
--- src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java	(revision 764493)
+++ src/main/java/org/apache/commons/compress/compressors/bzip2/BZip2CompressorOutputStream.java	(working copy)
@@ -709,9 +709,8 @@
     }
 
     private void init() throws IOException {
-        // write magic: done by caller who created this stream
-        // this.out.write('B');
-        // this.out.write('Z');
+        bsPutUByte('B');
+        bsPutUByte('Z');
 
         this.data = new Data(this.blockSize100k);
 
Index: src/test/java/org/apache/commons/compress/compressors/BZip2TestCase.java
===================================================================
--- src/test/java/org/apache/commons/compress/compressors/BZip2TestCase.java	(revision 764493)
+++ src/test/java/org/apache/commons/compress/compressors/BZip2TestCase.java	(working copy)
@@ -29,7 +29,7 @@
 
 public final class BZip2TestCase extends AbstractTestCase {
 
-	public void xtestBzipCreation()  throws Exception {
+	public void testBzipCreation()  throws Exception {
 	    File output = null;
 	    final File input = getFile("test.txt");
 	    {