diff options
| -rw-r--r-- | src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java b/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java index 062da8b..87910cb 100644 --- a/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java +++ b/src/main/java/com/att/nsa/mr/client/impl/MRSimplerBatchPublisher.java @@ -296,11 +296,7 @@ public class MRSimplerBatchPublisher extends MRBaseClient implements MRBatchingP props.getProperty("partition")); try { - /* - * final String contentType = fCompress ? - * MRFormat.CAMBRIA_ZIP.toString () : MRFormat.CAMBRIA.toString () ; - */ - + final ByteArrayOutputStream baseStream = new ByteArrayOutputStream(); OutputStream os = baseStream; final String contentType = props.getProperty("contenttype"); |