Repository: incubator-apex-malhar Updated Branches: refs/heads/feature-AppData 70a6653a6 -> 7e89a86f4
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/7e89a86f Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/7e89a86f Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/7e89a86f Branch: refs/heads/feature-AppData Commit: 7e89a86f435e179782e59aca610a7e9faecb263d Parents: 70a6653 Author: Timothy Farkas <[email protected]> Authored: Wed Aug 26 18:00:23 2015 -0700 Committer: Timothy Farkas <[email protected]> Committed: Wed Aug 26 18:25:19 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/7e89a86f/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")
