apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From che...@apache.org
Subject [16/50] incubator-apex-core git commit: Fixed the schema class missing error
Date Wed, 09 Sep 2015 22:12:47 GMT
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 <chandni@datatorrent.com>
Authored: Thu Aug 6 19:32:43 2015 -0700
Committer: Chandni Singh <chandni@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) {


Mime
View raw message