data.sfBuffer[data.iBufferPos] = sobjPass;
data.outputBuffer[data.iBufferPos] = rowData;
data.iBufferPos++;
}
if ( data.iBufferPos >= meta.getBatchSizeInt()) {
<BUG>if (log.isDetailed()) logDetailed("Calling flush buffer from writeToSalesForce");
flushBuffers();</BUG>
}
} catch (Exception e) {
<BUG>throw new KettleException("\nFailed in writeToSalesForce: "+ e.getMessage());
}</BUG>
}

data.sfBuffer[data.iBufferPos] = sobjPass;
data.outputBuffer[data.iBufferPos] = rowData;
data.iBufferPos++;
}
if ( data.iBufferPos >= meta.getBatchSizeInt()) {
if (log.isDetailed()) logDetailed(BaseMessages.getString(PKG, "SalesforceInsert.CallingFlushBuffer"));
flushBuffers();
}
} catch (Exception e) {
throw new KettleException(BaseMessages.getString(PKG, "SalesforceInsert.Error", e.getMessage()));
}
}
