svn commit: r1196238 - /incubator/jena/Jena2/ARQ/trunk/src/main/java/org/openjena/atlas/data/DefaultDataBag.java

[sa...@apache.org]

Author: sallen
Date: Tue Nov  1 19:41:13 2011
New Revision: 1196238

URL: http://svn.apache.org/viewvc?rev=1196238&view=rev
Log:
Small bug fix in DefaultDataBag.closeWriter().  Needed to check for the possibility that the threshold policy was exceeded but nothing was actually written out.

Modified:
    incubator/jena/Jena2/ARQ/trunk/src/main/java/org/openjena/atlas/data/DefaultDataBag.java

Modified: incubator/jena/Jena2/ARQ/trunk/src/main/java/org/openjena/atlas/data/DefaultDataBag.java
URL: http://svn.apache.org/viewvc/incubator/jena/Jena2/ARQ/trunk/src/main/java/org/openjena/atlas/data/DefaultDataBag.java?rev=1196238&r1=1196237&r2=1196238&view=diff
==============================================================================
--- incubator/jena/Jena2/ARQ/trunk/src/main/java/org/openjena/atlas/data/DefaultDataBag.java (original)
+++ incubator/jena/Jena2/ARQ/trunk/src/main/java/org/openjena/atlas/data/DefaultDataBag.java Tue Nov  1 19:41:13 2011
@@ -191,8 +191,16 @@ public class DefaultDataBag<E> extends A
         {
             if (policy.isThresholdExceeded())
             {
-                serializer.close();
-                IO.close(out);
+                // It is possible for "serializer" and "out" to be null even if the policy is exceeded.
+                // This can happen if nothing was ever added (i.e. a zero count policy)
+                if (null != serializer)
+                {
+                    serializer.close();
+                }
+                if (null != out)
+                {
+                    IO.close(out);
+                }
             }
             finishedAdding = true;
         }