You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:12:47 UTC
[16/50] incubator-apex-core git commit: Fixed the schema class
missing error
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 <ch...@datatorrent.com>
Authored: Thu Aug 6 19:32:43 2015 -0700
Committer: Chandni Singh <ch...@datatorrent.com>
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) {