Hi All, I'm using Storm 1.2.1 and facing an issue while trying to deploy my Trident DRPC topology. Trying to use persistentAggregate and this causes an error :
Exception in thread "main" java.lang.RuntimeException: InvalidTopologyException(msg:Component: [b-4] subscribes from non-existent component [$mastercoord-bg0]) at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:273) at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387) at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:159) You can find the details here : https://stackoverflow.com/questions/56564675/how-to-fix-error-component-x-subscribes-from-non-existent-component-y-in Then after some research I found this: https://grokbase.com/t/gg/storm-user/133kf7bttz/help-with-invalidtopologyexception Nathan Marz is stating that partitionPersist is not supported with DRPC as of 2013. I believe this is the same for persistentAggregate as well. I'd like to ask you if Storm 1.2.1 supports state persistence with DRPC or not. Thanks in advance! Best Regards, Goksenin
