Commit dfd9c96b by Shwetha GS

ATLAS-930 QuickStart is failing when run after a specific sequence of operations…

ATLAS-930 QuickStart is failing when run after a specific sequence of operations (yhemanth via shwethags)
parent 5b4cf440
...@@ -39,6 +39,7 @@ ATLAS-409 Atlas will not import avro tables with schema read from a file (dosset ...@@ -39,6 +39,7 @@ ATLAS-409 Atlas will not import avro tables with schema read from a file (dosset
ATLAS-379 Create sqoop and falcon metadata addons (venkatnrangan,bvellanki,sowmyaramesh via shwethags) ATLAS-379 Create sqoop and falcon metadata addons (venkatnrangan,bvellanki,sowmyaramesh via shwethags)
ALL CHANGES: ALL CHANGES:
ATLAS-930 QuickStart is failing when run after a specific sequence of operations (yhemanth via shwethags)
ATLAS-904 Hive hook fails due to session state not being set (sumasai via yhemanth) ATLAS-904 Hive hook fails due to session state not being set (sumasai via yhemanth)
ATLAS-929 Add test for trait preservation on column rename for non-default database (svimal2106 via shwethags) ATLAS-929 Add test for trait preservation on column rename for non-default database (svimal2106 via shwethags)
ATLAS-922 remove test atlas-application.properties embedded in atlas-typesystem.jar (madhan.neethiraj via yhemanth) ATLAS-922 remove test atlas-application.properties embedded in atlas-typesystem.jar (madhan.neethiraj via yhemanth)
......
...@@ -119,6 +119,7 @@ public class DataSetLineageService implements LineageService { ...@@ -119,6 +119,7 @@ public class DataSetLineageService implements LineageService {
} }
@Override @Override
@GraphTransaction
public String getInputsGraphForEntity(String guid) throws AtlasException { public String getInputsGraphForEntity(String guid) throws AtlasException {
LOG.info("Fetching lineage inputs graph for entity={}", guid); LOG.info("Fetching lineage inputs graph for entity={}", guid);
ParamChecker.notEmpty(guid, "Entity id"); ParamChecker.notEmpty(guid, "Entity id");
...@@ -136,6 +137,7 @@ public class DataSetLineageService implements LineageService { ...@@ -136,6 +137,7 @@ public class DataSetLineageService implements LineageService {
} }
@Override @Override
@GraphTransaction
public String getOutputsGraphForEntity(String guid) throws AtlasException { public String getOutputsGraphForEntity(String guid) throws AtlasException {
LOG.info("Fetching lineage outputs graph for entity guid={}", guid); LOG.info("Fetching lineage outputs graph for entity guid={}", guid);
ParamChecker.notEmpty(guid, "Entity id"); ParamChecker.notEmpty(guid, "Entity id");
...@@ -174,6 +176,7 @@ public class DataSetLineageService implements LineageService { ...@@ -174,6 +176,7 @@ public class DataSetLineageService implements LineageService {
} }
@Override @Override
@GraphTransaction
public String getSchemaForEntity(String guid) throws AtlasException { public String getSchemaForEntity(String guid) throws AtlasException {
ParamChecker.notEmpty(guid, "Entity id"); ParamChecker.notEmpty(guid, "Entity id");
LOG.info("Fetching schema for entity guid={}", guid); LOG.info("Fetching schema for entity guid={}", guid);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment