commit 1b4ff700e02adca6e77650dffd9b2330a725d472
author Sanjeev Kulkarni <sanjeev@streaml.io> Wed Oct 04 10:22:54 2017 -0700
committer Sanjeev Kulkarni <sanjeev@streaml.io> Wed Oct 04 10:22:54 2017 -0700
tree b3e391e5a226a2c7f175b1425146738ba3c6d7aa
parent f08512f9fbc417c7a5e7ef0cff1836577ccf44a0

For topologies submitted with older jars, topologuy reliability mode
will not exist.

heron/common/src/java/com/twitter/heron/common/utils/misc/PhysicalPlanHelper.java

diff --git a/heron/common/src/java/com/twitter/heron/common/utils/misc/PhysicalPlanHelper.java b/heron/common/src/java/com/twitter/heron/common/utils/misc/PhysicalPlanHelper.java
index ef491b4..9deb757 100644
--- a/heron/common/src/java/com/twitter/heron/common/utils/misc/PhysicalPlanHelper.java
+++ b/heron/common/src/java/com/twitter/heron/common/utils/misc/PhysicalPlanHelper.java
@@ -305,6 +305,9 @@
 
   public boolean isTopologyStateful() {
     Map<String, Object> config = topologyContext.getTopologyConfig();
+    if (config.get(Config.TOPOLOGY_RELIABILITY_MODE) == null) {
+      return false;
+    }
     Config.TopologyReliabilityMode mode =
         Config.TopologyReliabilityMode.valueOf(
             String.valueOf(config.get(Config.TOPOLOGY_RELIABILITY_MODE)));