apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From david...@apache.org
Subject [24/25] incubator-apex-malhar git commit: Fix NPE if an embeddable query info provider is not set on the snapshot server.
Date Sat, 29 Aug 2015 01:11:14 GMT
Fix NPE if an embeddable query info provider is not set on the snapshot server.


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/b24e99f7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/b24e99f7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/b24e99f7

Branch: refs/heads/feature-AppData
Commit: b24e99f74bb09350eeac22b5b7de482f86a6ccd7
Parents: d19f746
Author: Timothy Farkas <tim@datatorrent.com>
Authored: Wed Aug 26 18:00:23 2015 -0700
Committer: David Yan <david@datatorrent.com>
Committed: Fri Aug 28 18:09:32 2015 -0700

----------------------------------------------------------------------
 .../lib/appdata/snapshot/AbstractAppDataSnapshotServer.java      | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/b24e99f7/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java
b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java
index a51908f..af89109 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/snapshot/AbstractAppDataSnapshotServer.java
@@ -158,7 +158,9 @@ public abstract class AbstractAppDataSnapshotServer<INPUT_EVENT>
implements Oper
   @Override
   final public void activate(OperatorContext ctx)
   {
-    embeddableQueryInfoProvider.activate(ctx);
+    if (embeddableQueryInfoProvider != null) {
+      embeddableQueryInfoProvider.activate(ctx);
+    }
   }
 
   @SuppressWarnings("unchecked")


Mime
View raw message