statement should be transient
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/d96c3d85 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/d96c3d85 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/d96c3d85 Branch: refs/heads/master Commit: d96c3d85f54d8cad4722c96722b2f5380edd7e01 Parents: bd84a40 Author: Chandni Singh <[email protected]> Authored: Tue Jul 28 15:25:53 2015 -0700 Committer: David Yan <[email protected]> Committed: Tue Jul 28 15:30:19 2015 -0700 ---------------------------------------------------------------------- .../com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/d96c3d85/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java index 52679bf..a73f9e8 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcInputOperator.java @@ -44,7 +44,7 @@ import com.datatorrent.lib.db.AbstractStoreInputOperator; public abstract class AbstractJdbcInputOperator<T> extends AbstractStoreInputOperator<T, JdbcStore> { private static final Logger logger = LoggerFactory.getLogger(AbstractJdbcInputOperator.class); - Statement queryStatement = null; + protected transient Statement queryStatement; private transient int waitForDataTimeout; /**
