You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@batchee.apache.org by rm...@apache.org on 2015/11/24 13:51:42 UTC
incubator-batchee git commit: open writers anyway in MultiWriterBase
Repository: incubator-batchee
Updated Branches:
refs/heads/master b7a2fcd04 -> 93e36df30
open writers anyway in MultiWriterBase
Project: http://git-wip-us.apache.org/repos/asf/incubator-batchee/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-batchee/commit/93e36df3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-batchee/tree/93e36df3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-batchee/diff/93e36df3
Branch: refs/heads/master
Commit: 93e36df30873656aed93ea601b209c62850f655b
Parents: b7a2fcd
Author: Romain Manni-Bucau <rm...@gmail.com>
Authored: Tue Nov 24 13:51:44 2015 +0100
Committer: Romain Manni-Bucau <rm...@gmail.com>
Committed: Tue Nov 24 13:51:44 2015 +0100
----------------------------------------------------------------------
.../java/org/apache/batchee/extras/writer/MultiWriterBase.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-batchee/blob/93e36df3/extensions/extras/src/main/java/org/apache/batchee/extras/writer/MultiWriterBase.java
----------------------------------------------------------------------
diff --git a/extensions/extras/src/main/java/org/apache/batchee/extras/writer/MultiWriterBase.java b/extensions/extras/src/main/java/org/apache/batchee/extras/writer/MultiWriterBase.java
index affcc20..73dad21 100644
--- a/extensions/extras/src/main/java/org/apache/batchee/extras/writer/MultiWriterBase.java
+++ b/extensions/extras/src/main/java/org/apache/batchee/extras/writer/MultiWriterBase.java
@@ -44,6 +44,9 @@ public abstract class MultiWriterBase implements ItemWriter {
writer2.open(cp.checkpoint2);
} else if (serializable != null) {
throw new IllegalArgumentException(serializable + " unsupported");
+ } else {
+ writer1.open(null);
+ writer2.open(null);
}
}