src/main/java/org/embulk/output/PostgreSQLOutputPlugin.java in embulk-output-postgresql-0.8.2 vs src/main/java/org/embulk/output/PostgreSQLOutputPlugin.java in embulk-output-postgresql-0.8.3

@@ -75,11 +75,11 @@
             .setSupportedModes(ImmutableSet.of(Mode.INSERT, Mode.INSERT_DIRECT, Mode.MERGE, Mode.MERGE_DIRECT, Mode.TRUNCATE_INSERT, Mode.REPLACE))
             .setIgnoreMergeKeys(false);
     }
 
     @Override
-    protected PostgreSQLOutputConnector getConnector(PluginTask task, boolean retryableMetadataOperation)
+    protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMetadataOperation)
     {
         PostgreSQLPluginTask t = (PostgreSQLPluginTask) task;
 
         loadDriver("org.postgresql.Driver", t.getDriverPath());
 
@@ -112,10 +112,10 @@
 
         props.setProperty("user", t.getUser());
         props.setProperty("password", t.getPassword());
         logConnectionProperties(url, props);
 
-        return new PostgreSQLOutputConnector(url, props, t.getSchema());
+        return new PostgreSQLOutputConnector(url, props, t.getSchema(), t.getTransactionIsolation());
     }
 
     @Override
     protected TableIdentifier buildIntermediateTableId(JdbcOutputConnection con, PluginTask task, String tableName) {
         PostgreSQLPluginTask t = (PostgreSQLPluginTask) task;