svn commit: r1637606 - in /pig/trunk: CHANGES.txt test/org/apache/pig/impl/builtin/TestStreamingUDF.java

[da...@apache.org]

Author: daijy
Date: Sat Nov  8 22:39:39 2014
New Revision: 1637606

URL: http://svn.apache.org/r1637606
Log:
PIG-4312: TestStreamingUDF tez mode leave orphan process on Windows

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/test/org/apache/pig/impl/builtin/TestStreamingUDF.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1637606&r1=1637605&r2=1637606&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sat Nov  8 22:39:39 2014
@@ -114,6 +114,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4312: TestStreamingUDF tez mode leave orphan process on Windows (daijy)
+
 PIG-4314: BigData_5 hang on some machine (daijy)
 
 PIG-4299: SpillableMemoryManager assumes tenured heap incorrectly (prkommireddi via daijy)

Modified: pig/trunk/test/org/apache/pig/impl/builtin/TestStreamingUDF.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/impl/builtin/TestStreamingUDF.java?rev=1637606&r1=1637605&r2=1637606&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/impl/builtin/TestStreamingUDF.java (original)
+++ pig/trunk/test/org/apache/pig/impl/builtin/TestStreamingUDF.java Sat Nov  8 22:39:39 2014
@@ -35,7 +35,9 @@ import org.apache.pig.data.TupleFactory;
 import org.apache.pig.test.MiniGenericCluster;
 import org.apache.pig.test.Util;
 import org.joda.time.DateTime;
+import org.junit.AfterClass;
 import org.junit.Before;
+import org.junit.BeforeClass;
 import org.junit.Test;
 
 public class TestStreamingUDF {
@@ -43,7 +45,17 @@ public class TestStreamingUDF {
     private static PigServer pigServerMapReduce = null;
 
     private TupleFactory tf = TupleFactory.getInstance();
-    private static MiniGenericCluster cluster = MiniGenericCluster.buildCluster();
+    private static MiniGenericCluster cluster;
+
+    @BeforeClass
+    public static void oneTimeSetup() {
+        cluster = MiniGenericCluster.buildCluster();
+    }
+
+    @AfterClass
+    public static void oneTimeTearDown() throws Exception {
+        cluster.shutDown();
+    }
 
     @Before
     public void setUp() throws Exception {