From 4f98503c014c359b6ab018f43920d454b0344160 Mon Sep 17 00:00:00 2001
From: emopers <emopers@gmail.com>
Date: Thu, 4 Feb 2016 01:20:31 -0600
Subject: [PATCH] Fixing Usage of DataOutputStream

---
 .../test/java/org/apache/gora/accumulo/store/PartitionTest.java  | 1 +
 .../src/test/java/org/apache/gora/util/TestWritableUtils.java    | 1 +
 2 files changed, 2 insertions(+)

diff --git a/gora-accumulo/src/test/java/org/apache/gora/accumulo/store/PartitionTest.java b/gora-accumulo/src/test/java/org/apache/gora/accumulo/store/PartitionTest.java
index 3fcc04df4..b1ffd67eb 100644
--- a/gora-accumulo/src/test/java/org/apache/gora/accumulo/store/PartitionTest.java
+++ b/gora-accumulo/src/test/java/org/apache/gora/accumulo/store/PartitionTest.java
@@ -39,6 +39,7 @@ static long encl(long l) {
     DataOutputStream dos = new DataOutputStream(baos);
     try {
       dos.writeLong(l);
+      dos.flush();
     } catch (IOException e) {
       throw new RuntimeException(e);
     }
diff --git a/gora-core/src/test/java/org/apache/gora/util/TestWritableUtils.java b/gora-core/src/test/java/org/apache/gora/util/TestWritableUtils.java
index 59fe105b9..7b84aa9ab 100644
--- a/gora-core/src/test/java/org/apache/gora/util/TestWritableUtils.java
+++ b/gora-core/src/test/java/org/apache/gora/util/TestWritableUtils.java
@@ -44,6 +44,7 @@ public void testWritesReads() throws Exception {
     ByteArrayOutputStream bos = new ByteArrayOutputStream();
     DataOutput out = new DataOutputStream(bos);
     WritableUtils.writeProperties(out, props);
+    ((DataOutputStream)out).flush();
     
     DataInput in = new DataInputStream(new ByteArrayInputStream(bos.toByteArray()));