You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:31:58 UTC

[10/50] [abbrv] incubator-apex-malhar git commit: statement should be transient

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 <ch...@datatorrent.com>
Authored: Tue Jul 28 15:25:53 2015 -0700
Committer: David Yan <da...@datatorrent.com>
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;
 
   /**