Fixed the schema class missing error
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/430aec91 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/430aec91 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/430aec91 Branch: refs/heads/master Commit: 430aec9166c4ef02a3163b0d39d9e6aa16bae934 Parents: 19d6658 Author: Chandni Singh <[email protected]> Authored: Thu Aug 6 19:32:43 2015 -0700 Committer: Chandni Singh <[email protected]> Committed: Thu Aug 6 21:08:45 2015 -0700 ---------------------------------------------------------------------- .../stram/plan/logical/LogicalPlanConfiguration.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/430aec91/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlanConfiguration.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlanConfiguration.java b/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlanConfiguration.java index d838a2d..46291a8 100644 --- a/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlanConfiguration.java +++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlanConfiguration.java @@ -1135,11 +1135,7 @@ public class LogicalPlanConfiguration { String schemaClassName = streamConf.properties.getProperty(STREAM_SCHEMA); Class<?> schemaClass = null; if (schemaClassName != null) { - try { - schemaClass = Class.forName(schemaClassName); - } catch (ClassNotFoundException e) { - throw new ValidationException("schema class not found: " + schemaClassName); - } + schemaClass = StramUtils.classForName(schemaClassName, Object.class); } if (streamConf.sourceNode != null) {
