You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by bu...@apache.org on 2016/04/08 21:30:28 UTC
svn commit: r1738290 -
/uima/sandbox/uima-ducc/trunk/uima-ducc-database/src/main/java/org/apache/uima/ducc/database/HistoryManagerDb.java
Author: burn
Date: Fri Apr 8 19:30:28 2016
New Revision: 1738290
URL: http://svn.apache.org/viewvc?rev=1738290&view=rev
Log:
UIMA-4892 Don't truncate orckpt table
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-database/src/main/java/org/apache/uima/ducc/database/HistoryManagerDb.java
Modified: uima/sandbox/uima-ducc/trunk/uima-ducc-database/src/main/java/org/apache/uima/ducc/database/HistoryManagerDb.java
URL: http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-database/src/main/java/org/apache/uima/ducc/database/HistoryManagerDb.java?rev=1738290&r1=1738289&r2=1738290&view=diff
==============================================================================
--- uima/sandbox/uima-ducc/trunk/uima-ducc-database/src/main/java/org/apache/uima/ducc/database/HistoryManagerDb.java (original)
+++ uima/sandbox/uima-ducc/trunk/uima-ducc-database/src/main/java/org/apache/uima/ducc/database/HistoryManagerDb.java Fri Apr 8 19:30:28 2016
@@ -712,13 +712,6 @@ public class HistoryManagerDb
long now = System.currentTimeMillis();
boolean ret = true;
- // We transactionally delete the old checkpoint, and then save the new one. If something gows wrong we
- // rollback and thus don't lose stuff. In theory.
-
- // TODO: make the truncate and insert transactional
- DbHandle h = dbManager.open();
- h.truncate("ducc.orckpt");
-
try {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
ObjectOutputStream out = new ObjectOutputStream(baos);
@@ -742,7 +735,8 @@ public class HistoryManagerDb
bytes = baos.toByteArray();
ByteBuffer mapbuf = ByteBuffer.wrap(bytes);
- h = dbManager.open();
+ // Just insert/update the one row of checkpoint data - Jira 4892 - don't truncate as it creates snapshots
+ DbHandle h = dbManager.open();
h.saveObject(ckptPrepare, 0, workbuf, mapbuf);
} catch ( Exception e ) {