diff --git a/tap/src/main/java/ca/nrc/cadc/sample/QueryRunner.java b/tap/src/main/java/ca/nrc/cadc/sample/QueryRunner.java
index 8c1892e..5b8dd21 100644
--- a/tap/src/main/java/ca/nrc/cadc/sample/QueryRunner.java
+++ b/tap/src/main/java/ca/nrc/cadc/sample/QueryRunner.java
@@ -378,7 +378,7 @@ private void doIt()
                     // manually control transaction, make fetch size (client batch size) small,
                     // and restrict to forward only so that client memory usage is minimal since
                     // we are only interested in reading the ResultSet once
-
+                    connection.setAutoCommit(false);
                     pstmt = connection.prepareStatement(sql);
                     pstmt.setFetchSize(1000);
                     pstmt.setFetchDirection(ResultSet.FETCH_FORWARD);
diff --git a/tap/src/main/java/ca/nrc/cadc/sample/ResultStoreImpl.java b/tap/src/main/java/ca/nrc/cadc/sample/ResultStoreImpl.java
index 0298e23..b7ea6c0 100644
--- a/tap/src/main/java/ca/nrc/cadc/sample/ResultStoreImpl.java
+++ b/tap/src/main/java/ca/nrc/cadc/sample/ResultStoreImpl.java
@@ -137,7 +137,7 @@ private OutputStream getOutputStream() {
         BlobId blobId = BlobId.of(bucket, filename);
         BlobInfo blobInfo = BlobInfo.newBuilder(blobId).setContentType("application/x-votable+xml").build();
         Blob blob = storage.create(blobInfo);
-        return Channels.newOutputStream(blob.writer());
+        return Channels.newOutputStream(blob.writer())
     }
 
     private URL getURL() throws MalformedURLException {