diff --git a/src/java/com/cloudera/sqoop/manager/HsqldbManager.java b/src/java/com/cloudera/sqoop/manager/HsqldbManager.java index e79ab310..d34eee42 100644 --- a/src/java/com/cloudera/sqoop/manager/HsqldbManager.java +++ b/src/java/com/cloudera/sqoop/manager/HsqldbManager.java @@ -18,11 +18,17 @@ package com.cloudera.sqoop.manager; +import java.io.IOException; + import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import com.cloudera.sqoop.SqoopOptions; +import com.cloudera.sqoop.mapreduce.AsyncSqlOutputFormat; + +import com.cloudera.sqoop.util.ExportException; + /** * Manages connections to hsqldb databases. * Extends generic SQL manager. @@ -67,4 +73,14 @@ protected String getCurTimestampQuery() { public boolean supportsStagingForExport() { return true; } + + @Override + /** {@inheritDoc} */ + public void exportTable(ExportJobContext context) + throws IOException, ExportException { + // HSQLDB does not support multi-row inserts; disable that before export. + context.getOptions().getConf().setInt( + AsyncSqlOutputFormat.RECORDS_PER_STATEMENT_KEY, 1); + super.exportTable(context); + } }