Fix input/output

addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/hook/HiveHook.java

@@ -246,7 +246,7 @@ public class HiveHook implements ExecuteWithHookContext, HiveSemanticAnalyzerHoo
 
         LOG.debug("Registering CTAS query: {}", queryStr);
         Referenceable processReferenceable = new Referenceable(HiveDataTypes.HIVE_PROCESS.getName());
-        processReferenceable.set("processName", operation.getOperationName());
+        processReferenceable.set("name", operation.getOperationName());
         processReferenceable.set("startTime", queryStartTime);
         processReferenceable.set("userName", user);
         List<Referenceable> source = new ArrayList<>();

addons/hive-bridge/src/main/java/org/apache/hadoop/metadata/hive/model/HiveDataModelGenerator.java

@@ -480,7 +480,7 @@ public class HiveDataModelGenerator {
 
     private void createProcessClass() throws MetadataException {
         AttributeDefinition[] attributeDefinitions = new AttributeDefinition[]{
-                new AttributeDefinition("processName", DataTypes.STRING_TYPE.getName(),
+                new AttributeDefinition("name", DataTypes.STRING_TYPE.getName(),
                         Multiplicity.REQUIRED, false, null),
                 new AttributeDefinition("startTime", DataTypes.INT_TYPE.getName(),
                         Multiplicity.REQUIRED, false, null),

repository/src/main/java/org/apache/hadoop/metadata/discovery/HiveLineageService.java

@@ -100,7 +100,6 @@ public class HiveLineageService implements LineageService {
     public String getOutputs(String tableName) throws DiscoveryException {
         LOG.info("Fetching lineage outputs for tableName={}", tableName);
 
-        try {
         HiveWhereUsedQuery outputsQuery = new HiveWhereUsedQuery(
                 HIVE_TABLE_TYPE_NAME, tableName, HIVE_PROCESS_TYPE_NAME,
                 HIVE_PROCESS_INPUT_ATTRIBUTE_NAME, HIVE_PROCESS_OUTPUT_ATTRIBUTE_NAME,
@@ -108,9 +107,11 @@ public class HiveLineageService implements LineageService {
                 graphPersistenceStrategy, titanGraph);
 
         Expressions.Expression expression = outputsQuery.expr();
+        LOG.debug("Expression is [" + expression.toString() +"]");
+        try {
             return discoveryService.evaluate(expression).toJson();
         } catch (Exception e) { // unable to catch ExpressionException
-            throw new DiscoveryException("Invalid expression", e);
+            throw new DiscoveryException("Invalid expression [" + expression.toString() + "]", e);
         }
     }
 
@@ -124,7 +125,6 @@ public class HiveLineageService implements LineageService {
     public String getInputs(String tableName) throws DiscoveryException {
         LOG.info("Fetching lineage inputs for tableName={}", tableName);
 
-        try {
         HiveLineageQuery inputsQuery = new HiveLineageQuery(
                 HIVE_TABLE_TYPE_NAME, tableName, HIVE_PROCESS_TYPE_NAME,
                 HIVE_PROCESS_INPUT_ATTRIBUTE_NAME, HIVE_PROCESS_OUTPUT_ATTRIBUTE_NAME,
@@ -132,9 +132,11 @@ public class HiveLineageService implements LineageService {
                 graphPersistenceStrategy, titanGraph);
 
         Expressions.Expression expression = inputsQuery.expr();
+        LOG.debug("Expression is [" + expression.toString() +"]");
+        try {
             return discoveryService.evaluate(expression).toJson();
         } catch (Exception e) { // unable to catch ExpressionException
-            throw new DiscoveryException("Invalid expression", e);
+            throw new DiscoveryException("Invalid expression [" + expression.toString() + "]", e);
         }
     }
 

src/conf/application.properties

@@ -34,7 +34,7 @@ metadata.graph.index.search.elasticsearch.create.sleep=2000
 metadata.lineage.hive.table.type.name=hive_table
 metadata.lineage.hive.column.type.name=Column
 metadata.lineage.hive.table.column.name=columns
-metadata.lineage.hive.process.type.name=LoadProcess
+metadata.lineage.hive.process.type.name=hive_process
 metadata.lineage.hive.process.inputs.name=inputTables
 metadata.lineage.hive.process.outputs.name=outputTables