EAGLE-327: Fix topologyOperation start exception: java.lang.ClassCastException
https://issues.apache.org/jira/browse/EAGLE-327 Author: Zhao, Qingwen <qingwz...@ebay.com> Reviewer: Wu, Michael Closes #218 Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/f51474de Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/f51474de Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/f51474de Branch: refs/heads/master Commit: f51474dee0c6ab40b4df965871b5d723c06f84a3 Parents: 5a5a17c Author: Zhao, Qingwen <qingwz...@ebay.com> Authored: Mon Jun 6 10:25:05 2016 +0800 Committer: Zhao, Qingwen <qingwz...@ebay.com> Committed: Mon Jun 6 10:25:05 2016 +0800 ---------------------------------------------------------------------- .../apache/eagle/alert/executor/AlertExecutorCreationUtils.java | 2 +- .../eagle/datastream/core/StreamParallelismConfigExpansion.scala | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/f51474de/eagle-core/eagle-alert/eagle-alert-process/src/main/java/org/apache/eagle/alert/executor/AlertExecutorCreationUtils.java ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-alert/eagle-alert-process/src/main/java/org/apache/eagle/alert/executor/AlertExecutorCreationUtils.java b/eagle-core/eagle-alert/eagle-alert-process/src/main/java/org/apache/eagle/alert/executor/AlertExecutorCreationUtils.java index 8ab290e..8377267 100644 --- a/eagle-core/eagle-alert/eagle-alert-process/src/main/java/org/apache/eagle/alert/executor/AlertExecutorCreationUtils.java +++ b/eagle-core/eagle-alert/eagle-alert-process/src/main/java/org/apache/eagle/alert/executor/AlertExecutorCreationUtils.java @@ -81,7 +81,7 @@ public class AlertExecutorCreationUtils { if(alertExecutorConfigs !=null && alertExecutorConfigs.containsKey(alertExecutorId)) { Map<String, Object> alertExecutorConfig = (Map<String, Object>) alertExecutorConfigs.get(alertExecutorId).unwrapped(); int parts = 0; - if(alertExecutorConfig.containsKey("parallelism")) parts = (int) (alertExecutorConfig.get("parallelism")); + if(alertExecutorConfig.containsKey("parallelism")) parts = Integer.parseInt(alertExecutorConfig.get("parallelism").toString()); numPartitions = parts == 0 ? 1 : parts; if(alertExecutorConfig.containsKey("partitioner")) partitionerCls = (String) alertExecutorConfig.get("partitioner"); } http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/f51474de/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamParallelismConfigExpansion.scala ---------------------------------------------------------------------- diff --git a/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamParallelismConfigExpansion.scala b/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamParallelismConfigExpansion.scala index 8699da6..7ac9ff5 100644 --- a/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamParallelismConfigExpansion.scala +++ b/eagle-core/eagle-data-process/eagle-stream-process-api/src/main/scala/org/apache/eagle/datastream/core/StreamParallelismConfigExpansion.scala @@ -19,7 +19,7 @@ package org.apache.eagle.datastream.core import java.util.regex.Pattern -import com.typesafe.config.{Config, ConfigObject, ConfigValue} +import com.typesafe.config.{Config, ConfigObject} import org.jgrapht.experimental.dag.DirectedAcyclicGraph import org.slf4j.LoggerFactory @@ -48,7 +48,7 @@ case class StreamParallelismConfigExpansion(config: Config) extends StreamDAGExp if(config.hasPath("envContextConfig.parallelismConfig")) { val parallelismConfig: ConfigObject = config.getObject("envContextConfig.parallelismConfig") parallelismConfig.asScala.toMap map { - case (name, value) => (Pattern.compile(name), value.asInstanceOf[ConfigValue].unwrapped().asInstanceOf[Int]) + case (name, value) => (Pattern.compile(name), Integer.parseInt(value.unwrapped().toString)) } }else{ Map[Pattern,Int]()