[jira] [Created] (AMBARI-17667) Storm 1.0 Does Not Support Rolling Upgrades

["Jonathan Hurley (JIRA)" <ji...@apache.org>]

Jonathan Hurley created AMBARI-17667:
----------------------------------------

             Summary: Storm 1.0 Does Not Support Rolling Upgrades
                 Key: AMBARI-17667
                 URL: https://issues.apache.org/jira/browse/AMBARI-17667
             Project: Ambari
          Issue Type: Bug
          Components: ambari-server
    Affects Versions: 2.4.0
            Reporter: Jonathan Hurley
            Assignee: Jonathan Hurley
            Priority: Blocker
             Fix For: 2.4.0


HDP 2.5 includes a new version of Storm where packages named {{backtype.storm}} were changed to {{org.apache.storm}}. As a result, Storm local data is not compatible between versions earlier versions of HDP and HDP 2.5. Consider the following situatio where Nimbus and a Supervisor are co-located on the same host:

- Nimbus deletes local data and restarts on the downgrade version
- A running 2.5 Supervisor on the same host then re-creates that directory and puts 2.5 data back in
- When the 2.5 Supervisor goes to downgrade and restart, it can't delete that data again since Nimbus is already running and would stop.

When starting the Supevisor, the following error is seen:
{code}
2016-06-21 23:10:48.000 o.a.s.c.f.s.ConnectionStateManager [INFO] State change: CONNECTED
2016-06-21 23:10:48.058 b.s.d.supervisor [INFO] Starting supervisor with id 03d8bceb-0271-4076-810d-04aeaa91533c at host nat-os-r6-omns-dgm10toeriedwngdha-r6-2.openstacklocal
2016-06-21 23:10:48.785 b.s.event [ERROR] Error when processing event
java.lang.RuntimeException: java.lang.ClassNotFoundException: org.apache.storm.generated.LSSupervisorAssignments
        at backtype.storm.utils.LocalState.deserialize(LocalState.java:83) ~[storm-core-0.10.0.2.4.2.0-258.jar:0.10.0.2.4.2.0-258]
        at backtype.storm.utils.LocalState.get(LocalState.java:130) ~[storm-core-0.10.0.2.4.2.0-258.jar:0.10.0.2.4.2.0-258]
        at backtype.storm.local_state$ls_local_assignments.invoke(local_state.clj:83) ~[storm-core-0.10.0.2.4.2.0-258.jar:0.10.0.2.4.2.0-258]
        at backtype.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:323) ~[storm-core-0.10.0.2.4.2.0-258.jar:0.10.0.2.4.2.0-258]
        at clojure.lang.AFn.applyToHelper(AFn.java:154) ~[clojure-1.6.0.jar:?]
        at clojure.lang.AFn.applyTo(AFn.java:144) ~[clojure-1.6.0.jar:?]
        at clojure.core$apply.invoke(core.clj:626) ~[clojure-1.6.0.jar:?]
        at clojure.core$partial$fn__4228.doInvoke(core.clj:2468) ~[clojure-1.6.0.jar:?]
        at clojure.lang.RestFn.invoke(RestFn.java:397) ~[clojure-1.6.0.jar:?]
        at backtype.storm.event$event_manager$fn__6135.invoke(event.clj:40) [storm-core-0.10.0.2.4.2.0-258.jar:0.10.0.2.4.2.0-258]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.7.0_67]
Caused by: java.lang.ClassNotFoundException: org.apache.storm.generated.LSSupervisorAssignments
        at java.net.URLClassLoader$1.run(URLClassLoader.java:366) ~[?:1.7.0_67]
        at java.net.URLClassLoader$1.run(URLClassLoader.java:355) ~[?:1.7.0_67]
        at java.security.AccessController.doPrivileged(Native Method) ~[?:1.7.0_67]
        at java.net.URLClassLoader.findClass(URLClassLoader.java:354) ~[?:1.7.0_67]
        at java.lang.ClassLoader.loadClass(ClassLoader.java:425) ~[?:1.7.0_67]
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) ~[?:1.7.0_67]
        at java.lang.ClassLoader.loadClass(ClassLoader.java:358) ~[?:1.7.0_67]
        at java.lang.Class.forName0(Native Method) ~[?:1.7.0_67]
        at java.lang.Class.forName(Class.java:190) ~[?:1.7.0_67]
        at backtype.storm.utils.LocalState.deserialize(LocalState.java:78) ~[storm-core-0.10.0.2.4.2.0-258.jar:0.10.0.2.4.2.0-258]
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)