svn commit: r1545900 - in /oozie/trunk/core/src/test/java/org/apache/oozie/util: TestSimplifiedTimestampedMessageParser.java TestTimestampedMessageParser.java

[mona]

Author: mona
Date: Wed Nov 27 01:17:06 2013
New Revision: 1545900

URL: http://svn.apache.org/r1545900
Log:
committing minor unit test change to be part of OOZIE-1474

Modified:
    
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestSimplifiedTimestampedMessageParser.java
    
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestTimestampedMessageParser.java

Modified: 
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestSimplifiedTimestampedMessageParser.java
URL: 
http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/util/TestSimplifiedTimestampedMessageParser.java?rev=1545900&r1=1545899&r2=1545900&view=diff
==============================================================================
--- 
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestSimplifiedTimestampedMessageParser.java
 (original)
+++ 
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestSimplifiedTimestampedMessageParser.java
 Wed Nov 27 01:17:06 2013
@@ -41,7 +41,7 @@ public class TestSimplifiedTimestampedMe
 
         File file = 
TestTimestampedMessageParser.prepareFile1(getTestCaseDir());
         StringWriter sw = new StringWriter();
-        new SimpleTimestampedMessageParser(new BufferedReader(new 
FileReader(file)), xf).processRemaining(sw);
+        new SimpleTimestampedMessageParser(new BufferedReader(new 
FileReader(file)), xf).processRemaining(sw, 4096);
         String[] out = sw.toString().split("\n");
         assertEquals(19, out.length);
         assertTrue(out[0].contains("_L1_"));
@@ -79,7 +79,7 @@ public class TestSimplifiedTimestampedMe
 
         File file = 
TestTimestampedMessageParser.prepareFile2(getTestCaseDir());
         StringWriter sw = new StringWriter();
-        new SimpleTimestampedMessageParser(new BufferedReader(new 
FileReader(file)), xf).processRemaining(sw);
+        new SimpleTimestampedMessageParser(new BufferedReader(new 
FileReader(file)), xf).processRemaining(sw, 4096);
         String[] matches = sw.toString().split("\n");
         assertEquals(9, matches.length);
         assertTrue(matches[0].contains("_L1_"));

Modified: 
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestTimestampedMessageParser.java
URL: 
http://svn.apache.org/viewvc/oozie/trunk/core/src/test/java/org/apache/oozie/util/TestTimestampedMessageParser.java?rev=1545900&r1=1545899&r2=1545900&view=diff
==============================================================================
--- 
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestTimestampedMessageParser.java
 (original)
+++ 
oozie/trunk/core/src/test/java/org/apache/oozie/util/TestTimestampedMessageParser.java
 Wed Nov 27 01:17:06 2013
@@ -111,7 +111,7 @@ public class TestTimestampedMessageParse
 
         File file = prepareFile1(getTestCaseDir());
         StringWriter sw = new StringWriter();
-        new TimestampedMessageParser(new BufferedReader(new FileReader(file)), 
xf).processRemaining(sw);
+        new TimestampedMessageParser(new BufferedReader(new FileReader(file)), 
xf).processRemaining(sw, 4096);
         String[] out = sw.toString().split("\n");
         assertEquals(14, out.length);
         assertTrue(out[0].contains("_L1_"));
@@ -144,7 +144,7 @@ public class TestTimestampedMessageParse
 
         File file = prepareFile2(getTestCaseDir());
         StringWriter sw = new StringWriter();
-        new TimestampedMessageParser(new BufferedReader(new FileReader(file)), 
xf).processRemaining(sw);
+        new TimestampedMessageParser(new BufferedReader(new FileReader(file)), 
xf).processRemaining(sw, 4096);
         String[] matches = sw.toString().split("\n");
         assertEquals(2, matches.length);
         assertTrue(matches[0].contains("_L1_"));