[jira] [Updated] (ATLAS-2932) Update DSL to use Java Traversal API

2021-01-07 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-2932:
---
Attachment: (was: dsl-traversal-2.1.patch)

> Update DSL to use Java Traversal API
> 
>
> Key: ATLAS-2932
> URL: https://issues.apache.org/jira/browse/ATLAS-2932
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 1.0.0, trunk
>Reporter: Apoorv Naik
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> 0002-ATLAS-2932-Update-DSL-to-use-Tinkerpop-Java-APIs-ins.patch, 
> dsl-traversal-v2.3.patch
>
>
> Change DSL code to use Java Tinkerpop Traversals instead of 
> GremlinScriptEngine



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-2932) Update DSL to use Java Traversal API

2021-01-07 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-2932:
---
Attachment: dsl-traversal-2.1.patch

> Update DSL to use Java Traversal API
> 
>
> Key: ATLAS-2932
> URL: https://issues.apache.org/jira/browse/ATLAS-2932
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 1.0.0, trunk
>Reporter: Apoorv Naik
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> 0002-ATLAS-2932-Update-DSL-to-use-Tinkerpop-Java-APIs-ins.patch, 
> dsl-traversal-2.1.patch
>
>
> Change DSL code to use Java Tinkerpop Traversals instead of 
> GremlinScriptEngine



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4068) Export/Import Service: Conditionally Support Simultaneous Operations

2020-12-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4068:
---
Attachment: ATLAS-4068-Export-Import-Conditionally-Support-Simpu.patch

> Export/Import Service: Conditionally Support Simultaneous Operations
> 
>
> Key: ATLAS-4068
> URL: https://issues.apache.org/jira/browse/ATLAS-4068
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-4068-Export-Import-Conditionally-Support-Simpu.patch
>
>
> *Background*
> Existing implementation for Export & Import REST APIs disallows more than one 
> operation at a time.
> *Solution*
> Loosen the criteria based on request:
>  * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
>  * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.
> Operations where these options are not specified, the existing behavior will 
> continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-4068) Export/Import Service: Conditionally Support Simultaneous Operations

2020-12-09 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246872#comment-17246872
 ] 

Ashutosh Mestry commented on ATLAS-4068:


Addressed review comments.

> Export/Import Service: Conditionally Support Simultaneous Operations
> 
>
> Key: ATLAS-4068
> URL: https://issues.apache.org/jira/browse/ATLAS-4068
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-4068-Export-Import-Conditionally-Support-Simpu.patch
>
>
> *Background*
> Existing implementation for Export & Import REST APIs disallows more than one 
> operation at a time.
> *Solution*
> Loosen the criteria based on request:
>  * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
>  * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.
> Operations where these options are not specified, the existing behavior will 
> continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4068) Export/Import Service: Conditionally Support Simultaneous Operations

2020-12-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4068:
---
Attachment: (was: 
ATLAS-4068-Support-simultaneous-export-and-import-op.patch)

> Export/Import Service: Conditionally Support Simultaneous Operations
> 
>
> Key: ATLAS-4068
> URL: https://issues.apache.org/jira/browse/ATLAS-4068
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
>
> *Background*
> Existing implementation for Export & Import REST APIs disallows more than one 
> operation at a time.
> *Solution*
> Loosen the criteria based on request:
>  * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
>  * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.
> Operations where these options are not specified, the existing behavior will 
> continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4068) Export/Import Service: Conditionally Support Simultaneous Operations

2020-12-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4068:
---
Summary: Export/Import Service: Conditionally Support Simultaneous 
Operations  (was: Export/Import Service: Conditionally Support Multiple 
Operations)

> Export/Import Service: Conditionally Support Simultaneous Operations
> 
>
> Key: ATLAS-4068
> URL: https://issues.apache.org/jira/browse/ATLAS-4068
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-4068-Support-simultaneous-export-and-import-op.patch
>
>
> *Background*
> Existing implementation for Export & Import REST APIs disallows more than one 
> operation at a time.
> *Solution*
> Loosen the criteria based on request:
>  * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
>  * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.
> Operations where these options are not specified, the existing behavior will 
> continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-4068) Export/Import Service: Conditionally Support Multiple Operations

2020-12-09 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17246838#comment-17246838
 ] 

Ashutosh Mestry commented on ATLAS-4068:


PC build: 
https://ci-builds.apache.org/job/Atlas/job/PreCommit-ATLAS-Build-Test/257/

> Export/Import Service: Conditionally Support Multiple Operations
> 
>
> Key: ATLAS-4068
> URL: https://issues.apache.org/jira/browse/ATLAS-4068
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-4068-Support-simultaneous-export-and-import-op.patch
>
>
> *Background*
> Existing implementation for Export & Import REST APIs disallows more than one 
> operation at a time.
> *Solution*
> Loosen the criteria based on request:
>  * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
>  * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.
> Operations where these options are not specified, the existing behavior will 
> continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-4069) Export/Importing a recreated deleted entity has the relationshipStatus set to ACTIVE instead of DELETED for deleted entity

2020-12-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-4069:
--

Assignee: Ashutosh Mestry

> Export/Importing a recreated deleted entity has the relationshipStatus set to 
> ACTIVE instead of DELETED for deleted entity
> --
>
> Key: ATLAS-4069
> URL: https://issues.apache.org/jira/browse/ATLAS-4069
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: Screenshot 2020-12-09 at 5.51.10 PM.png
>
>
> Run the below queries:
>  # create database IF NOT EXISTS database34_${var:rand_str};
>  # create table IF NOT EXISTS 
> database34_${var:rand_str}.table_${var:rand_str}_34(id int,name string,dob 
> date);
>  # drop table database34_${var:rand_str}.table_${var:rand_str}_34;
>  # drop database database34_${var:rand_str};
>  # create database IF NOT EXISTS database34_${var:rand_str};
>  # create table IF NOT EXISTS 
> database34_${var:rand_str}.table_${var:rand_str}_34(id int,name string,dob 
> date);
> As you can see, create a database/table, followed by drop statements, and 
> then recreated them.
> Hence, there are 2 entities with same name, but the state is different (1 is 
> ACTIVE, 1 is DELETED).
> Text compare: !Screenshot 2020-12-09 at 5.51.10 PM.png!
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4068) Export/Import Service: Conditionally Support Multiple Operations

2020-12-08 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4068:
---
Attachment: ATLAS-4068-Support-simultaneous-export-and-import-op.patch

> Export/Import Service: Conditionally Support Multiple Operations
> 
>
> Key: ATLAS-4068
> URL: https://issues.apache.org/jira/browse/ATLAS-4068
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-4068-Support-simultaneous-export-and-import-op.patch
>
>
> *Background*
> Existing implementation for Export & Import REST APIs disallows more than one 
> operation at a time.
> *Solution*
> Loosen the criteria based on request:
>  * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
>  * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.
> Operations where these options are not specified, the existing behavior will 
> continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-4068) Export/Import Service: Conditionally Support Multiple Operations

2020-12-08 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-4068:
--

 Summary: Export/Import Service: Conditionally Support Multiple 
Operations
 Key: ATLAS-4068
 URL: https://issues.apache.org/jira/browse/ATLAS-4068
 Project: Atlas
  Issue Type: Improvement
  Components:  atlas-core
Affects Versions: 2.1.0
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry
 Fix For: trunk


*Background*

Existing implementation for Export & Import REST APIs disallows more than one 
operation at a time.

*Solution*

Loosen the criteria based on request:
 * Export: _AtlasExportRequest_: _skipLineage_ and _replicatedTo_ is selected.
 * Import: _AtlasImportRequest_: _replicatedFrom_ is selected.

Operations where these options are not specified, the existing behavior will 
continue.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Reopened] (ATLAS-4047) Audits Framework: Handling Long List

2020-11-30 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reopened ATLAS-4047:


> Audits Framework: Handling Long List
> 
>
> Key: ATLAS-4047
> URL: https://issues.apache.org/jira/browse/ATLAS-4047
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4047-AtlasAuditService-Handling-large-strings.patch
>
>
> *Background*
> Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object 
> ids) and attempts to store it in a vertex.
> *Steps to Duplicate*
> Setup:
>  * Create an export payload with 50 tables each with about 50 columns.
> Steps to duplicate:
>  * Attempt to import. Import succeeds.
> Expected result: Import completes successfully.
> Actual result: Following exception is seen within the log, import returns and 
> error code:
> {code:java}
> at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
>  at 
> org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
>  at 
> org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
>  at 
> org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
>  at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
> at 
> org.apache.atlas.repository.audit.AtlasAuditService.save(AtlasAuditService.java:62)
>  at 
> org.apache.atlas.repository.audit.AtlasAuditService.add(AtlasAuditService.java:82)
>  at 
> org.apache.atlas.repository.audit.AtlasAuditService$$FastClassBySpringCGLIB$$2eddda47.invoke()
>  at 
> org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204){code}
>  CC: [~mandar.ambaw...@freestoneinfotech.com]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (ATLAS-3032) Importing an entity with tag attribute of type float data type fails with an BigDecimal Exception

2020-11-25 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry resolved ATLAS-3032.

Resolution: Fixed

Fixed by: https://issues.apache.org/jira/browse/ATLAS-1876

> Importing an entity with tag attribute of type float data type fails with an 
> BigDecimal Exception
> -
>
> Key: ATLAS-3032
> URL: https://issues.apache.org/jira/browse/ATLAS-3032
> Project: Atlas
>  Issue Type: Bug
>Reporter: Kapildeo Nayak
>Assignee: Ashutosh Mestry
>Priority: Critical
> Attachments: ATLAS-3032.patch
>
>
> # In source cluster , created a tag with float attribute.
>  2. Created an hive_db and associated the tag to the hive_db with value 
> "-3.4028235E+38"
>  3. On importing the exported hive_db entity, exception is seen and import 
> fails.
> Following stack trace is generated:
> {code:java}
> org.apache.atlas.repository.graphdb.AtlasSchemaViolationException: 
> com.thinkaurelius.titan.core.SchemaViolationException: Value [-3.4028235E+38] 
> is not an instance of the expected data type for property key 
> [tag_float.float] and cannot be converted. Expected: class java.lang.Float, 
> found: class java.math.BigDecimal{code}
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-4048) Import Service: Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17238443#comment-17238443
 ] 

Ashutosh Mestry commented on ATLAS-4048:


[~madhan] I have modified the steps. My earlier steps were inaccurate.

> Import Service: Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>
> *Background*
> Business Metadata attributes provide a simple way to augment attributes to 
> existing entity types.
> Updating Business Metadata for existing entities via REST APIs did not happen 
> as the changes were not tracked when considering entity for update.
> *Steps to Duplicate*
> Setup:
>  * Create a source cluster, say cl1.
>  * Create a destination cluster, say cl2.
> Steps to duplicate:
>  # On cl1: Create Business Metadata say bm1. Add 3 attributes to an entity, 
> say t1. Perform export.
>  # On cl2: Use Import REST API, perform import on a different cluster, say 
> cl2.
>  # On cl1: Edit the entity t1. Remove 2 of the 3 BM attributes. Perform 
> export.
>  # On cl2: Perform import.
> Expected results: On cl2: Entity t1 will have 1 business metadata attribute.
> Actual result: On cl2, Entity t1 contains all 3 attributes from step 1.
>  *Root Cause*
> During entity creation flow, the Business Metadata attributes are not 
> considered when detecting if entity has changes. 
> Solution: Add a step to detect changes to Business Metadata attributes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Import Service: Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Description: 
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create a source cluster, say cl1.
 * Create a destination cluster, say cl2.

Steps to duplicate:
 # On cl1: Create Business Metadata say bm1. Add 3 attributes to an entity, say 
t1. Perform export.
 # On cl2: Use Import REST API, perform import on a different cluster, say cl2.
 # On cl1: Edit the entity t1. Remove 2 of the 3 BM attributes. Perform export.
 # On cl2: Perform import.

Expected results: On cl2: Entity t1 will have 1 business metadata attribute.

Actual result: On cl2, Entity t1 contains all 3 attributes from step 1.

 *Root Cause*

During entity creation flow, the Business Metadata attributes are not 
considered when detecting if entity has changes. 

Solution: Add a step to detect changes to Business Metadata attributes.

  was:
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create Business Metadata and add 3 attributes.
 * Create an exported ZIP file.

Steps to duplicate:
 # Via REST API, create an entity with 3 Business Metadata attributes. 
 # From the web UI, load the entity where attributes have been added.
 # Delete 1 attribute.
 # Use entity update REST API to update the entity from step 1.

Expected results: Entity will have all 3 attributes.

Actual result: Entity will contain only 2 attributes that were present in step 
2.

 *Root Cause*

During entity creation flow, the Business Metadata attributes are not 
considered when detecting if entity has changes. 

Solution: Add a step to detect changes to Business Metadata attributes.


> Import Service: Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>
> *Background*
> Business Metadata attributes provide a simple way to augment attributes to 
> existing entity types.
> Updating Business Metadata for existing entities via REST APIs did not happen 
> as the changes were not tracked when considering entity for update.
> *Steps to Duplicate*
> Setup:
>  * Create a source cluster, say cl1.
>  * Create a destination cluster, say cl2.
> Steps to duplicate:
>  # On cl1: Create Business Metadata say bm1. Add 3 attributes to an entity, 
> say t1. Perform export.
>  # On cl2: Use Import REST API, perform import on a different cluster, say 
> cl2.
>  # On cl1: Edit the entity t1. Remove 2 of the 3 BM attributes. Perform 
> export.
>  # On cl2: Perform import.
> Expected results: On cl2: Entity t1 will have 1 business metadata attribute.
> Actual result: On cl2, Entity t1 contains all 3 attributes from step 1.
>  *Root Cause*
> During entity creation flow, the Business Metadata attributes are not 
> considered when detecting if entity has changes. 
> Solution: Add a step to detect changes to Business Metadata attributes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Import Service: Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Summary: Import Service: Entity Creation: Updates to Business Metadata  
(was: Entity Creation: Updates to Business Metadata)

> Import Service: Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>
> *Background*
> Business Metadata attributes provide a simple way to augment attributes to 
> existing entity types.
> Updating Business Metadata for existing entities via REST APIs did not happen 
> as the changes were not tracked when considering entity for update.
> *Steps to Duplicate*
> Setup:
>  * Create Business Metadata and add 3 attributes.
>  * Create an exported ZIP file.
> Steps to duplicate:
>  # Via REST API, create an entity with 3 Business Metadata attributes. 
>  # From the web UI, load the entity where attributes have been added.
>  # Delete 1 attribute.
>  # Use entity update REST API to update the entity from step 1.
> Expected results: Entity will have all 3 attributes.
> Actual result: Entity will contain only 2 attributes that were present in 
> step 2.
>  *Root Cause*
> During entity creation flow, the Business Metadata attributes are not 
> considered when detecting if entity has changes. 
> Solution: Add a step to detect changes to Business Metadata attributes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Description: 
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create Business Metadata and add 3 attributes.
 * Create an exported ZIP file.

Steps to duplicate:
 # Via REST API, create an entity with 3 Business Metadata attributes. 
 # From the web UI, load the entity where attributes have been added.
 # Delete 1 attribute.
 # Use entity update REST API to update the entity from step 1.

Expected results: Entity will have all 3 attributes.

Actual result: Entity will contain only 2 attributes that were present in step 
2.

 *Root Cause*

During entity creation flow, the Business Metadata attributes are not 
considered when detecting if entity has changes. 

Solution: Add a step to detect changes to Business Metadata attributes.

  was:
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create Business Metadata and add 3 attributes.

Steps to duplicate:
 # Via REST API, create an entity with 3 Business Metadata attributes. 
 # From the web UI, load the entity where attributes have been added.
 # Delete 1 attribute.
 # Use entity update REST API to update the entity from step 1.

Expected results: Entity will have all 3 attributes.

Actual result: Entity will contain only 2 attributes that were present in step 
2.

 *Root Cause*

During entity creation flow, the Business Metadata attributes are not 
considered when detecting if entity has changes. 

Solution: Add a step to detect changes to Business Metadata attributes.


> Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>
> *Background*
> Business Metadata attributes provide a simple way to augment attributes to 
> existing entity types.
> Updating Business Metadata for existing entities via REST APIs did not happen 
> as the changes were not tracked when considering entity for update.
> *Steps to Duplicate*
> Setup:
>  * Create Business Metadata and add 3 attributes.
>  * Create an exported ZIP file.
> Steps to duplicate:
>  # Via REST API, create an entity with 3 Business Metadata attributes. 
>  # From the web UI, load the entity where attributes have been added.
>  # Delete 1 attribute.
>  # Use entity update REST API to update the entity from step 1.
> Expected results: Entity will have all 3 attributes.
> Actual result: Entity will contain only 2 attributes that were present in 
> step 2.
>  *Root Cause*
> During entity creation flow, the Business Metadata attributes are not 
> considered when detecting if entity has changes. 
> Solution: Add a step to detect changes to Business Metadata attributes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Description: 
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create Business Metadata and add 3 attributes.

Steps to duplicate:
 # Via REST API, create an entity with 3 Business Metadata attributes. 
 # From the web UI, load the entity where attributes have been added.
 # Delete 1 attribute.
 # Use entity update REST API to update the entity from step 1.

Expected results: Entity will have all 3 attributes.

Actual result: Entity will contain only 2 attributes that were present in step 
2.

 *Root Cause*

During entity creation flow, the Business Metadata attributes are not 
considered when detecting if entity has changes. 

Solution: Add a step to detect changes to Business Metadata attributes.

  was:
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create Business Metadata and add 3 attributes.

Steps to duplicate:
 # Via REST API, create an entity with 3 Business Metadata attributes. 
 # From the web UI, load the entity where attributes have been added.
 # Delete 1 attribute.
 # Use entity update REST API to update the entity from step 1.

Expected results: Entity will have all 3 attributes.

Actual result: Entity will contain only 2 attributes that were present in step 
2.

 


> Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>
> *Background*
> Business Metadata attributes provide a simple way to augment attributes to 
> existing entity types.
> Updating Business Metadata for existing entities via REST APIs did not happen 
> as the changes were not tracked when considering entity for update.
> *Steps to Duplicate*
> Setup:
>  * Create Business Metadata and add 3 attributes.
> Steps to duplicate:
>  # Via REST API, create an entity with 3 Business Metadata attributes. 
>  # From the web UI, load the entity where attributes have been added.
>  # Delete 1 attribute.
>  # Use entity update REST API to update the entity from step 1.
> Expected results: Entity will have all 3 attributes.
> Actual result: Entity will contain only 2 attributes that were present in 
> step 2.
>  *Root Cause*
> During entity creation flow, the Business Metadata attributes are not 
> considered when detecting if entity has changes. 
> Solution: Add a step to detect changes to Business Metadata attributes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Description: 
*Background*

Business Metadata attributes provide a simple way to augment attributes to 
existing entity types.

Updating Business Metadata for existing entities via REST APIs did not happen 
as the changes were not tracked when considering entity for update.

*Steps to Duplicate*

Setup:
 * Create Business Metadata and add 3 attributes.

Steps to duplicate:
 # Via REST API, create an entity with 3 Business Metadata attributes. 
 # From the web UI, load the entity where attributes have been added.
 # Delete 1 attribute.
 # Use entity update REST API to update the entity from step 1.

Expected results: Entity will have all 3 attributes.

Actual result: Entity will contain only 2 attributes that were present in step 
2.

 

> Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>
> *Background*
> Business Metadata attributes provide a simple way to augment attributes to 
> existing entity types.
> Updating Business Metadata for existing entities via REST APIs did not happen 
> as the changes were not tracked when considering entity for update.
> *Steps to Duplicate*
> Setup:
>  * Create Business Metadata and add 3 attributes.
> Steps to duplicate:
>  # Via REST API, create an entity with 3 Business Metadata attributes. 
>  # From the web UI, load the entity where attributes have been added.
>  # Delete 1 attribute.
>  # Use entity update REST API to update the entity from step 1.
> Expected results: Entity will have all 3 attributes.
> Actual result: Entity will contain only 2 attributes that were present in 
> step 2.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Priority: Major  (was: Blocker)

> Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Entity Creation: Updates to Business Metadata

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Summary: Entity Creation: Updates to Business Metadata  (was: Issue with 
Business Metadata in Export/Import APIs)

> Entity Creation: Updates to Business Metadata
> -
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Blocker
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4048) Issue with Business Metadata in Export/Import APIs

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4048:
---
Attachment: ATLAS-4048-Entity-Update-Businessmetada-changes.patch

> Issue with Business Metadata in Export/Import APIs
> --
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Blocker
> Attachments: ATLAS-4048-Entity-Update-Businessmetada-changes.patch
>
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-4048) Issue with Business Metadata in Export/Import APIs

2020-11-24 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-4048:
--

Assignee: Ashutosh Mestry

> Issue with Business Metadata in Export/Import APIs
> --
>
> Key: ATLAS-4048
> URL: https://issues.apache.org/jira/browse/ATLAS-4048
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Blocker
>




--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4047) Audits Framework: Handling Large Object List

2020-11-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4047:
---
Attachment: ATLAS-4047-AtlasAuditService-Handling-large-strings.patch

> Audits Framework: Handling Large Object List
> 
>
> Key: ATLAS-4047
> URL: https://issues.apache.org/jira/browse/ATLAS-4047
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4047-AtlasAuditService-Handling-large-strings.patch
>
>
> *Background*
> Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object 
> ids) and attempts to store it in a vertex.
> *Steps to Duplicate*
> Setup:
>  * Create an export payload with 50 tables each with about 50 columns.
> Steps to duplicate:
>  * Attempt to import. Import succeeds.
> Expected result: Import completes successfully.
> Actual result: Following exception is seen within the log, import returns and 
> error code:
> {code:java}
> at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
>  at 
> org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
>  at 
> org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
>  at 
> org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
>  at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
> at 
> org.apache.atlas.repository.audit.AtlasAuditService.save(AtlasAuditService.java:62)
>  at 
> org.apache.atlas.repository.audit.AtlasAuditService.add(AtlasAuditService.java:82)
>  at 
> org.apache.atlas.repository.audit.AtlasAuditService$$FastClassBySpringCGLIB$$2eddda47.invoke()
>  at 
> org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204){code}
>  CC: [~mandar.ambaw...@freestoneinfotech.com]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4047) Audits Framework: Handling Long List

2020-11-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4047:
---
Summary: Audits Framework: Handling Long List  (was: Audits Framework: 
Handling Large Object List)

> Audits Framework: Handling Long List
> 
>
> Key: ATLAS-4047
> URL: https://issues.apache.org/jira/browse/ATLAS-4047
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4047-AtlasAuditService-Handling-large-strings.patch
>
>
> *Background*
> Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object 
> ids) and attempts to store it in a vertex.
> *Steps to Duplicate*
> Setup:
>  * Create an export payload with 50 tables each with about 50 columns.
> Steps to duplicate:
>  * Attempt to import. Import succeeds.
> Expected result: Import completes successfully.
> Actual result: Following exception is seen within the log, import returns and 
> error code:
> {code:java}
> at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
>  at 
> org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
>  at 
> org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
>  at 
> org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
>  at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
> at 
> org.apache.atlas.repository.audit.AtlasAuditService.save(AtlasAuditService.java:62)
>  at 
> org.apache.atlas.repository.audit.AtlasAuditService.add(AtlasAuditService.java:82)
>  at 
> org.apache.atlas.repository.audit.AtlasAuditService$$FastClassBySpringCGLIB$$2eddda47.invoke()
>  at 
> org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204){code}
>  CC: [~mandar.ambaw...@freestoneinfotech.com]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4047) Audits Framework: Handling Large Object List

2020-11-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4047:
---
Description: 
*Background*

Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object ids) 
and attempts to store it in a vertex.

*Steps to Duplicate*

Setup:
 * Create an export payload with 50 tables each with about 50 columns.

Steps to duplicate:
 * Attempt to import. Import succeeds.

Expected result: Import completes successfully.

Actual result: Following exception is seen within the log, import returns and 
error code:
{code:java}
at 
org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
 at 
org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
 at 
org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
 at 
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
 at 
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
 at 
org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
 at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
at 
org.apache.atlas.repository.audit.AtlasAuditService.save(AtlasAuditService.java:62)
 at 
org.apache.atlas.repository.audit.AtlasAuditService.add(AtlasAuditService.java:82)
 at 
org.apache.atlas.repository.audit.AtlasAuditService$$FastClassBySpringCGLIB$$2eddda47.invoke()
 at 
org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204){code}
 CC: [~mandar.ambaw...@freestoneinfotech.com]

  was:
*Background*

Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object ids) 
and attempts to store it in a vertex.

*Steps to Duplicate*

Setup:
 * Create an export payload with 50 tables each with about 50 columns.

Steps to duplicate:
 * Attempt to import. Import succeeds.

Expected result: Import completes successfully.

Actual result: Following exception is seen within the log, import returns and 
error code:
{code:java}
at 
org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
 at 
org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
 at 
org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
 at 
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
 at 
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
 at 
org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
 at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
at 
org.apache.atlas.repository.audit.AtlasAuditService.save(AtlasAuditService.java:62)
 at 
org.apache.atlas.repository.audit.AtlasAuditService.add(AtlasAuditService.java:82)
 at 
org.apache.atlas.repository.audit.AtlasAuditService$$FastClassBySpringCGLIB$$2eddda47.invoke()
 at 
org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204){code}
 


> Audits Framework: Handling Large Object List
> 
>
> Key: ATLAS-4047
> URL: https://issues.apache.org/jira/browse/ATLAS-4047
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
>
> *Background*
> Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object 
> ids) and attempts to store it in a vertex.
> *Steps to Duplicate*
> Setup:
>  * Create an export payload with 50 tables each with about 50 columns.
> Steps to duplicate:
>  * Attempt to import. Import succeeds.
> Expected result: Import completes successfully.
> Actual result: Following exception is seen within the log, import returns and 
> error code:
> {code:java}
> at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
>  at 
> org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
>  at 
> org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
>  at 
> org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
>  at 
> org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
>  at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
> at 
> 

[jira] [Created] (ATLAS-4047) Audits Framework: Handling Large Object List

2020-11-23 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-4047:
--

 Summary: Audits Framework: Handling Large Object List
 Key: ATLAS-4047
 URL: https://issues.apache.org/jira/browse/ATLAS-4047
 Project: Atlas
  Issue Type: Bug
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry


*Background*

Existing _AtlasAuditService_ implementation, accepts list of GUIDs (object ids) 
and attempts to store it in a vertex.

*Steps to Duplicate*

Setup:
 * Create an export payload with 50 tables each with about 50 columns.

Steps to duplicate:
 * Attempt to import. Import succeeds.

Expected result: Import completes successfully.

Actual result: Following exception is seen within the log, import returns and 
error code:
{code:java}
at 
org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
 at 
org.apache.atlas.GraphTransactionInterceptor.doCommitOrRollback(GraphTransactionInterceptor.java:177)
 at 
org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTransactionInterceptor.java:116)
 at 
org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
 at 
org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:672)
 at 
org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2$$EnhancerBySpringCGLIB$$f28200fc.createOrUpdate()
 at org.apache.atlas.repository.ogm.DataAccess.saveNoLoad(DataAccess.java:73) 
at 
org.apache.atlas.repository.audit.AtlasAuditService.save(AtlasAuditService.java:62)
 at 
org.apache.atlas.repository.audit.AtlasAuditService.add(AtlasAuditService.java:82)
 at 
org.apache.atlas.repository.audit.AtlasAuditService$$FastClassBySpringCGLIB$$2eddda47.invoke()
 at 
org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204){code}
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4024) Atlas terms are not imported to target cluster using Atlas export/import API

2020-11-20 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4024:
---
Attachment: ATLAS-4024-Terms-not-getting-exported-in-incremental.patch

> Atlas terms are not imported to target cluster using Atlas export/import API
> 
>
> Key: ATLAS-4024
> URL: https://issues.apache.org/jira/browse/ATLAS-4024
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4024-Terms-not-getting-exported-in-incremental.patch, destination.png, 
> source.png
>
>
> Created a table with name "src_test5_t1" and assigned "test term" to 
> it.Created a table with name "src_test5_t1" and assigned "test term" to it.
> Atlas export API was then run with below payload:
> {code:java}
> { "itemsToExport": [{ "typeName": "hive_db", "uniqueAttributes": { 
> "qualifiedName": "src_test5@cm" } }], "options": {  "replicatedTo": "cm",  
> "fetchType": "incremental",  "skipLineage": true,  "changeMarker": 0 },  
> "fetchTypeOptionValue": "incremental",  "skipLineageOptionValue": true,  
> "changeTokenFromOptions": 0}  {code}
> Atlas Import was run with below payload:
> {code:java}
> { { options = { transformers: [{ "conditions": { "__entity": "topLevel: " }, 
> "action": { "__entity": "ADD_CLASSIFICATION: cm_replicated" } }, { "action": 
> { "__entity.replicatedTo": "CLEAR:", "__entity.replicatedFrom": "CLEAR:" } }, 
> { "conditions": { "hive_db.clusterName": "EQUALS: cm" }, "action": { 
> "hive_db.clusterName": "SET: cm" } }, { "conditions": { "hive_db.name": 
> "EQUALS: src_test5" }, "action": { "hive_db.name": "SET: tgt_test5" } }, { 
> "conditions": { "hive_db.location": "STARTS_WITH_IGNORE_CASE: 
> hdfs://host:8020" }, "action": { "hive_db.location": "REPLACE_PREFIX: = 
> :hdfs://host:8020=hdfs://host:8020" } }, { "conditions": { 
> "hive_storagedesc.location": "STARTS_WITH_IGNORE_CASE: hdfs://host:8020" }, 
> "action": { "hive_storagedesc.location": "REPLACE_PREFIX: = 
> :hdfs://host:8020=hdfs://host:8020" } }], replicatedFrom: cm, size: 1 } } 
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-4024) Atlas terms are not imported to target cluster using Atlas export/import API

2020-11-20 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-4024:
--

Assignee: Ashutosh Mestry

> Atlas terms are not imported to target cluster using Atlas export/import API
> 
>
> Key: ATLAS-4024
> URL: https://issues.apache.org/jira/browse/ATLAS-4024
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4024-Terms-not-getting-exported-in-incremental.patch, destination.png, 
> source.png
>
>
> Created a table with name "src_test5_t1" and assigned "test term" to 
> it.Created a table with name "src_test5_t1" and assigned "test term" to it.
> Atlas export API was then run with below payload:
> {code:java}
> { "itemsToExport": [{ "typeName": "hive_db", "uniqueAttributes": { 
> "qualifiedName": "src_test5@cm" } }], "options": {  "replicatedTo": "cm",  
> "fetchType": "incremental",  "skipLineage": true,  "changeMarker": 0 },  
> "fetchTypeOptionValue": "incremental",  "skipLineageOptionValue": true,  
> "changeTokenFromOptions": 0}  {code}
> Atlas Import was run with below payload:
> {code:java}
> { { options = { transformers: [{ "conditions": { "__entity": "topLevel: " }, 
> "action": { "__entity": "ADD_CLASSIFICATION: cm_replicated" } }, { "action": 
> { "__entity.replicatedTo": "CLEAR:", "__entity.replicatedFrom": "CLEAR:" } }, 
> { "conditions": { "hive_db.clusterName": "EQUALS: cm" }, "action": { 
> "hive_db.clusterName": "SET: cm" } }, { "conditions": { "hive_db.name": 
> "EQUALS: src_test5" }, "action": { "hive_db.name": "SET: tgt_test5" } }, { 
> "conditions": { "hive_db.location": "STARTS_WITH_IGNORE_CASE: 
> hdfs://host:8020" }, "action": { "hive_db.location": "REPLACE_PREFIX: = 
> :hdfs://host:8020=hdfs://host:8020" } }, { "conditions": { 
> "hive_storagedesc.location": "STARTS_WITH_IGNORE_CASE: hdfs://host:8020" }, 
> "action": { "hive_storagedesc.location": "REPLACE_PREFIX: = 
> :hdfs://host:8020=hdfs://host:8020" } }], replicatedFrom: cm, size: 1 } } 
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-11-20 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry resolved ATLAS-3941.

Resolution: Fixed

> NotificationHookConsumer: Reduce Retry Pause Interval
> -
>
> Key: ATLAS-3941
> URL: https://issues.apache.org/jira/browse/ATLAS-3941
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3941-Notification-Consumer-Reduce-pause-time-o.patch
>
>
> *Background*
> The retry logic introduced earlier, had a long wait time in case a concurrent 
> entity create was detected. This adversely affect ingest speed in the case 
> where there are a lot of errors in the data being ingested.
> *Solution*
> Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-13 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry resolved ATLAS-4015.

Resolution: Fixed

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH-master.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. This leads to incorrect basic search 
> output. Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4025) [Export/Import] Removing a classification from the entity in source cluster does not remove the classification in target cluster

2020-11-13 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4025:
---
Attachment: ATLAS-4023-Import-Service-Label-and-Classification-e.patch

> [Export/Import] Removing a classification from the entity in source cluster 
> does not remove the classification in target cluster 
> -
>
> Key: ATLAS-4025
> URL: https://issues.apache.org/jira/browse/ATLAS-4025
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4023-Import-Service-Label-and-Classification-e.patch
>
>
> Steps to reproduce:
>  # Created a table src_test8_t1 in the source cluster
>  # Assigned the classification "test_classification" to the src_test8_t1 
> hive_table entity in source cluster
>  # Ran Atlas export in source, followed by import in target cluster
>  # Entity src_test8_t1 was created in target cluster with classification 
> "test_classification" assigned to it correctly
>  # Now, I removed the classification "test_classification" from the entity 
> src_test8_t1 in source cluster
>  # Ran Atlas export in source, followed by import in target cluster
>  # Now, the expectation is the classification "test_classification" is 
> removed in the target cluster from the entity src_test8_t1. But it is not, 
> classification is still assigned to the entity 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-4025) [Export/Import] Removing a classification from the entity in source cluster does not remove the classification in target cluster

2020-11-13 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-4025:
--

Assignee: Ashutosh Mestry

> [Export/Import] Removing a classification from the entity in source cluster 
> does not remove the classification in target cluster 
> -
>
> Key: ATLAS-4025
> URL: https://issues.apache.org/jira/browse/ATLAS-4025
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Major
>
> Steps to reproduce:
>  # Created a table src_test8_t1 in the source cluster
>  # Assigned the classification "test_classification" to the src_test8_t1 
> hive_table entity in source cluster
>  # Ran Atlas export in source, followed by import in target cluster
>  # Entity src_test8_t1 was created in target cluster with classification 
> "test_classification" assigned to it correctly
>  # Now, I removed the classification "test_classification" from the entity 
> src_test8_t1 in source cluster
>  # Ran Atlas export in source, followed by import in target cluster
>  # Now, the expectation is the classification "test_classification" is 
> removed in the target cluster from the entity src_test8_t1. But it is not, 
> classification is still assigned to the entity 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4023) Import Service: Labels Not Importing Correctly

2020-11-12 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4023:
---
Summary: Import Service: Labels Not Importing Correctly  (was: Import 
Service: Labels and Classifications Not Importing Correctly)

> Import Service: Labels Not Importing Correctly
> --
>
> Key: ATLAS-4023
> URL: https://issues.apache.org/jira/browse/ATLAS-4023
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4023-Import-Service-Label-and-Classification-e.patch
>
>
> *Steps to Duplicate*
>  # Create dataset with _hive_db, hive_table,_ say _t1_.
>  # Add label to _hive_table,_ say _label1, label2_.
>  # Perform _Import_. Import succeeds with _hive_table_ getting assigned 
> labels _label1_ and _label2_.
>  # Modify _t1_ such that it has only _label1_.
>  # Perform Import.
> Expected result: _t1_ should have _label1._
> Actual result: _t1_ has _label1_ and _label2._
> *Additional Information*
> Similar exercise can be performed with classifications.
>  
> Original reporter: [~umesh.padashetty]  Thanks you!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4023) Import Service: Labels Not Importing Correctly

2020-11-12 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4023:
---
Description: 
*Steps to Duplicate*
 # Create dataset with _hive_db, hive_table,_ say _t1_.
 # Add label to _hive_table,_ say _label1, label2_.
 # Perform _Import_. Import succeeds with _hive_table_ getting assigned labels 
_label1_ and _label2_.
 # Modify _t1_ such that it has only _label1_.
 # Perform Import.

Expected result: _t1_ should have _label1._

Actual result: _t1_ has _label1_ and _label2._

 Original reporter: [~umesh.padashetty]  Thanks you!

  was:
*Steps to Duplicate*
 # Create dataset with _hive_db, hive_table,_ say _t1_.
 # Add label to _hive_table,_ say _label1, label2_.
 # Perform _Import_. Import succeeds with _hive_table_ getting assigned labels 
_label1_ and _label2_.
 # Modify _t1_ such that it has only _label1_.
 # Perform Import.

Expected result: _t1_ should have _label1._

Actual result: _t1_ has _label1_ and _label2._

*Additional Information*

Similar exercise can be performed with classifications.

 

Original reporter: [~umesh.padashetty]  Thanks you!


> Import Service: Labels Not Importing Correctly
> --
>
> Key: ATLAS-4023
> URL: https://issues.apache.org/jira/browse/ATLAS-4023
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4023-Import-Service-Label-and-Classification-e.patch
>
>
> *Steps to Duplicate*
>  # Create dataset with _hive_db, hive_table,_ say _t1_.
>  # Add label to _hive_table,_ say _label1, label2_.
>  # Perform _Import_. Import succeeds with _hive_table_ getting assigned 
> labels _label1_ and _label2_.
>  # Modify _t1_ such that it has only _label1_.
>  # Perform Import.
> Expected result: _t1_ should have _label1._
> Actual result: _t1_ has _label1_ and _label2._
>  Original reporter: [~umesh.padashetty]  Thanks you!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4023) Import Service: Labels and Classifications Not Importing Correctly

2020-11-12 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4023:
---
Description: 
*Steps to Duplicate*
 # Create dataset with _hive_db, hive_table,_ say _t1_.
 # Add label to _hive_table,_ say _label1, label2_.
 # Perform _Import_. Import succeeds with _hive_table_ getting assigned labels 
_label1_ and _label2_.
 # Modify _t1_ such that it has only _label1_.
 # Perform Import.

Expected result: _t1_ should have _label1._

Actual result: _t1_ has _label1_ and _label2._

*Additional Information*

Similar exercise can be performed with classifications.

 

Original reporter: [~umesh.padashetty]  Thanks you!

  was:
*Steps to Duplicate*
 # Create dataset with _hive_db, hive_table,_ say _t1_.
 # Add label to _hive_table,_ say _label1, label2_.
 # Perform _Import_. Import succeeds with _hive_table_ getting assigned labels 
_label1_ and _label2_.
 # Modify _t1_ such that it has only _label1_.
 # Perform Import.

Expected result: _t1_ should have _label1._

Actual result: _t1_ has _label1_ and _label2._

*Additional Information*

Similar exercise can be performed with classifications.


> Import Service: Labels and Classifications Not Importing Correctly
> --
>
> Key: ATLAS-4023
> URL: https://issues.apache.org/jira/browse/ATLAS-4023
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4023-Import-Service-Label-and-Classification-e.patch
>
>
> *Steps to Duplicate*
>  # Create dataset with _hive_db, hive_table,_ say _t1_.
>  # Add label to _hive_table,_ say _label1, label2_.
>  # Perform _Import_. Import succeeds with _hive_table_ getting assigned 
> labels _label1_ and _label2_.
>  # Modify _t1_ such that it has only _label1_.
>  # Perform Import.
> Expected result: _t1_ should have _label1._
> Actual result: _t1_ has _label1_ and _label2._
> *Additional Information*
> Similar exercise can be performed with classifications.
>  
> Original reporter: [~umesh.padashetty]  Thanks you!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-4023) Import Service: Labels and Classifications Not Importing Correctly

2020-11-12 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231167#comment-17231167
 ] 

Ashutosh Mestry commented on ATLAS-4023:


Pre-commit build: 
https://ci-builds.apache.org/job/Atlas/job/PreCommit-ATLAS-Build-Test/188/

> Import Service: Labels and Classifications Not Importing Correctly
> --
>
> Key: ATLAS-4023
> URL: https://issues.apache.org/jira/browse/ATLAS-4023
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4023-Import-Service-Label-and-Classification-e.patch
>
>
> *Steps to Duplicate*
>  # Create dataset with _hive_db, hive_table,_ say _t1_.
>  # Add label to _hive_table,_ say _label1, label2_.
>  # Perform _Import_. Import succeeds with _hive_table_ getting assigned 
> labels _label1_ and _label2_.
>  # Modify _t1_ such that it has only _label1_.
>  # Perform Import.
> Expected result: _t1_ should have _label1._
> Actual result: _t1_ has _label1_ and _label2._
> *Additional Information*
> Similar exercise can be performed with classifications.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-11-12 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3941:
---
Attachment: (was: 
ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch)

> NotificationHookConsumer: Reduce Retry Pause Interval
> -
>
> Key: ATLAS-3941
> URL: https://issues.apache.org/jira/browse/ATLAS-3941
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3941-Notification-Consumer-Reduce-pause-time-o.patch
>
>
> *Background*
> The retry logic introduced earlier, had a long wait time in case a concurrent 
> entity create was detected. This adversely affect ingest speed in the case 
> where there are a lot of errors in the data being ingested.
> *Solution*
> Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-11-12 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3941:
---
Attachment: ATLAS-3941-Notification-Consumer-Reduce-pause-time-o.patch

> NotificationHookConsumer: Reduce Retry Pause Interval
> -
>
> Key: ATLAS-3941
> URL: https://issues.apache.org/jira/browse/ATLAS-3941
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3941-Notification-Consumer-Reduce-pause-time-o.patch
>
>
> *Background*
> The retry logic introduced earlier, had a long wait time in case a concurrent 
> entity create was detected. This adversely affect ingest speed in the case 
> where there are a lot of errors in the data being ingested.
> *Solution*
> Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4023) Import Service: Labels and Classifications Not Importing Correctly

2020-11-12 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4023:
---
Attachment: ATLAS-4023-Import-Service-Label-and-Classification-e.patch

> Import Service: Labels and Classifications Not Importing Correctly
> --
>
> Key: ATLAS-4023
> URL: https://issues.apache.org/jira/browse/ATLAS-4023
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-4023-Import-Service-Label-and-Classification-e.patch
>
>
> *Steps to Duplicate*
>  # Create dataset with _hive_db, hive_table,_ say _t1_.
>  # Add label to _hive_table,_ say _label1, label2_.
>  # Perform _Import_. Import succeeds with _hive_table_ getting assigned 
> labels _label1_ and _label2_.
>  # Modify _t1_ such that it has only _label1_.
>  # Perform Import.
> Expected result: _t1_ should have _label1._
> Actual result: _t1_ has _label1_ and _label2._
> *Additional Information*
> Similar exercise can be performed with classifications.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-4023) Import Service: Labels and Classifications Not Importing Correctly

2020-11-12 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-4023:
--

 Summary: Import Service: Labels and Classifications Not Importing 
Correctly
 Key: ATLAS-4023
 URL: https://issues.apache.org/jira/browse/ATLAS-4023
 Project: Atlas
  Issue Type: Bug
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry


*Steps to Duplicate*
 # Create dataset with _hive_db, hive_table,_ say _t1_.
 # Add label to _hive_table,_ say _label1, label2_.
 # Perform _Import_. Import succeeds with _hive_table_ getting assigned labels 
_label1_ and _label2_.
 # Modify _t1_ such that it has only _label1_.
 # Perform Import.

Expected result: _t1_ should have _label1._

Actual result: _t1_ has _label1_ and _label2._

*Additional Information*

Similar exercise can be performed with classifications.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4015:
---
Description: 
*Background*

Every so often, we encounter cases where the Solr indexes are out of sync with 
the data stored in the database. This leads to incorrect basic search output. 
Additionally the facet numbers displayed are also incorrect.

*Solution*

It may help to make the ReIndex functionality to be made part of one of 
JAVA_PATCH handlers that can be applied only when end user notices a problem 
like described above.

 

  was:
*Background*

Every so often, we encounter cases where the Solr indexes are out of sync with 
the data stored in the database. The is leads basic search output. Additionally 
the facet numbers displayed are also incorrect.

*Solution*

It may help to make the ReIndex functionality to be made part of one of 
JAVA_PATCH handlers that can be applied only when end user notices a problem 
like described above.

 


> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH-master.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. This leads to incorrect basic search 
> output. Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4015:
---
Attachment: (was: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch)

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH-master.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. The is leads basic search output. 
> Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4015:
---
Attachment: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH-master.patch

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH-master.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. The is leads basic search output. 
> Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-09 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17228711#comment-17228711
 ] 

Ashutosh Mestry commented on ATLAS-4015:


With the new implementation I am able to process 16M vertices in ~5 hrs. I will 
open RB item for regular review.

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. The is leads basic search output. 
> Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4015:
---
Attachment: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. The is leads basic search output. 
> Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4015:
---
Attachment: (was: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch)

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. The is leads basic search output. 
> Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-06 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4015:
---
Attachment: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch

> Indexes: Add Conditional Re-Indexing Patch
> --
>
> Key: ATLAS-4015
> URL: https://issues.apache.org/jira/browse/ATLAS-4015
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-4015-Add-Re-indexing-as-JAVA_PATCH.patch
>
>
> *Background*
> Every so often, we encounter cases where the Solr indexes are out of sync 
> with the data stored in the database. The is leads basic search output. 
> Additionally the facet numbers displayed are also incorrect.
> *Solution*
> It may help to make the ReIndex functionality to be made part of one of 
> JAVA_PATCH handlers that can be applied only when end user notices a problem 
> like described above.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-4015) Indexes: Add Conditional Re-Indexing Patch

2020-11-06 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-4015:
--

 Summary: Indexes: Add Conditional Re-Indexing Patch
 Key: ATLAS-4015
 URL: https://issues.apache.org/jira/browse/ATLAS-4015
 Project: Atlas
  Issue Type: Improvement
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry


*Background*

Every so often, we encounter cases where the Solr indexes are out of sync with 
the data stored in the database. The is leads basic search output. Additionally 
the facet numbers displayed are also incorrect.

*Solution*

It may help to make the ReIndex functionality to be made part of one of 
JAVA_PATCH handlers that can be applied only when end user notices a problem 
like described above.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-4010) Sort properties lexicographically in pom.xml for readability

2020-10-29 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-4010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223403#comment-17223403
 ] 

Ashutosh Mestry commented on ATLAS-4010:


PC build: 
[https://ci-builds.apache.org/job/Atlas/job/PreCommit-ATLAS-Build-Test/168/]

 

> Sort properties lexicographically in pom.xml for readability
> 
>
> Key: ATLAS-4010
> URL: https://issues.apache.org/jira/browse/ATLAS-4010
> Project: Atlas
>  Issue Type: Task
>Reporter: Radhika Kundam
>Assignee: Radhika Kundam
>Priority: Trivial
>
> Properties are in random order under  section in pom.xml
> For better readability, need to sort properties in lexicographic order.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4007) Support for Business Metadata in Atlas Import API

2020-10-25 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4007:
---
Attachment: 
ATLAS-4006-ATLAS-4007-Export-Import-Added-support-for-Business-.patch

> Support for Business Metadata in Atlas Import API
> -
>
> Key: ATLAS-4007
> URL: https://issues.apache.org/jira/browse/ATLAS-4007
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Critical
> Attachments: 
> ATLAS-4006-ATLAS-4007-Export-Import-Added-support-for-Business-.patch
>
>
> Business metadata definition and Entity's Business metadata details are not 
> imported currently via Atlas Import API, we need to build support for this.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-4006) Support for Business Metadata in Atlas Export API

2020-10-25 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-4006:
---
Attachment: 
ATLAS-4006-ATLAS-4007-Export-Import-Added-support-for-Business-.patch

> Support for Business Metadata in Atlas Export API
> -
>
> Key: ATLAS-4006
> URL: https://issues.apache.org/jira/browse/ATLAS-4006
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Critical
> Attachments: 
> ATLAS-4006-ATLAS-4007-Export-Import-Added-support-for-Business-.patch
>
>
> Business metadata definition and Entity's Business metadata details are not 
> exported currently via Atlas Export API, we need to build support for this.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-4007) Support for Business Metadata in Atlas Import API

2020-10-25 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-4007:
--

Assignee: Ashutosh Mestry

> Support for Business Metadata in Atlas Import API
> -
>
> Key: ATLAS-4007
> URL: https://issues.apache.org/jira/browse/ATLAS-4007
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Critical
>
> Business metadata definition and Entity's Business metadata details are not 
> imported currently via Atlas Import API, we need to build support for this.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-4006) Support for Business Metadata in Atlas Export API

2020-10-25 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-4006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-4006:
--

Assignee: Ashutosh Mestry

> Support for Business Metadata in Atlas Export API
> -
>
> Key: ATLAS-4006
> URL: https://issues.apache.org/jira/browse/ATLAS-4006
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 2.1.0
>Reporter: Umesh Padashetty
>Assignee: Ashutosh Mestry
>Priority: Critical
>
> Business metadata definition and Entity's Business metadata details are not 
> exported currently via Atlas Export API, we need to build support for this.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3977) Migration Script: Deleted entities in Atlas1.0 miss few attributes after migrated to Atlas2.0

2020-10-13 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3977:
---
Attachment: 
ATLAS-3977-Deleted-entity-behavior-fix-during-migrat-Part-2.patch

> Migration Script: Deleted entities in Atlas1.0 miss few attributes after 
> migrated to Atlas2.0
> -
>
> Key: ATLAS-3977
> URL: https://issues.apache.org/jira/browse/ATLAS-3977
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Sharmadha S
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-3977-Addressed-patch-processing-for.patch, 
> ATLAS-3977-Deleted-entity-behavior-fix-during-migrat-Part-2.patch, 
> am2cm_deleted_active_entity.png
>
>
> table6 is DELETED in Atlas1.0 and it is migrated to Atals2.0
> Attributes like name , db , owner are missing in DELETED entities whereas 
> they are populated correctly in ACTIVE entities.
> Attaching the screenshot.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3989) Behavior change in Atlas API to get Atlas Server object during metadata replication

2020-10-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3989:
---
Attachment: ATLAS-3989-Updated-Export-Import-Audits-Writer-to-us.patch

> Behavior change in Atlas API to get Atlas Server object during metadata 
> replication
> ---
>
> Key: ATLAS-3989
> URL: https://issues.apache.org/jira/browse/ATLAS-3989
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-3989-Updated-Export-Import-Audits-Writer-to-us.patch
>
>
> There is a change being noticed in the Atlas server API used during atlas 
> metadata replication in hive.
>  Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster 
> name, used to work.
>  Now, it doesn't work any more. This Api is used during replication to get 
> the changeMarker info.
>  Now the API works with some thing called server name which is 'default' by 
> default.
>  Also, now the prerequisite is to at least have one export or import API call 
> in order to get this 'default' initialized.
>  The change-marker is obtained prior to invoking export and hence the all 
> policy is bound to fail unless we mandate calling Export or Import API 
> outside hive replication once to get this object initialized, even if hive 
> uses 'default' in the call.
>  
> *Root cause*
> We switched from using
> {code:java}
> atlas.cluster.name{code}
> to
> {code:java}
> atlas.metadata.namespace{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3989) Behavior change in Atlas API to get Atlas Server object during metadata replication

2020-10-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3989:
---
Attachment: (was: 
ATLAS-3989-Updated-Export-Import-Audits-Writer-to-us.patch)

> Behavior change in Atlas API to get Atlas Server object during metadata 
> replication
> ---
>
> Key: ATLAS-3989
> URL: https://issues.apache.org/jira/browse/ATLAS-3989
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
>
> There is a change being noticed in the Atlas server API used during atlas 
> metadata replication in hive.
>  Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster 
> name, used to work.
>  Now, it doesn't work any more. This Api is used during replication to get 
> the changeMarker info.
>  Now the API works with some thing called server name which is 'default' by 
> default.
>  Also, now the prerequisite is to at least have one export or import API call 
> in order to get this 'default' initialized.
>  The change-marker is obtained prior to invoking export and hence the all 
> policy is bound to fail unless we mandate calling Export or Import API 
> outside hive replication once to get this object initialized, even if hive 
> uses 'default' in the call.
>  
> *Root cause*
> We switched from using
> {code:java}
> atlas.cluster.name{code}
> to
> {code:java}
> atlas.metadata.namespace{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3989) Behavior change in Atlas API to get Atlas Server object during metadata replication

2020-10-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3989:
---
Description: 
There is a change being noticed in the Atlas server API used during atlas 
metadata replication in hive.
 Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster 
name, used to work.
 Now, it doesn't work any more. This Api is used during replication to get the 
changeMarker info.
 Now the API works with some thing called server name which is 'default' by 
default.
 Also, now the prerequisite is to at least have one export or import API call 
in order to get this 'default' initialized.
 The change-marker is obtained prior to invoking export and hence the all 
policy is bound to fail unless we mandate calling Export or Import API outside 
hive replication once to get this object initialized, even if hive uses 
'default' in the call.

 

*Root cause*

We switched from using
{code:java}
atlas.cluster.name{code}
to
{code:java}
atlas.metadata.namespace{code}

  was:
There is a change being noticed in the Atlas server API used during atlas 
metadata replication in hive.
Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster name, 
used to work.
Now, it doesn't work any more. This Api is used during replication to get the 
changeMarker info.
Now the API works with some thing called server name which is 'default' by 
default.
Also, now the prerequisite is to at least have one export or import API call in 
order to get this 'default' initialized.
The change-marker is obtained prior to invoking export and hence the all policy 
is bound to fail unless we mandate calling Export or Import API outside hive 
replication once to get this object initialized, even if hive uses 'default' in 
the call.


> Behavior change in Atlas API to get Atlas Server object during metadata 
> replication
> ---
>
> Key: ATLAS-3989
> URL: https://issues.apache.org/jira/browse/ATLAS-3989
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-3989-Updated-Export-Import-Audits-Writer-to-us.patch
>
>
> There is a change being noticed in the Atlas server API used during atlas 
> metadata replication in hive.
>  Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster 
> name, used to work.
>  Now, it doesn't work any more. This Api is used during replication to get 
> the changeMarker info.
>  Now the API works with some thing called server name which is 'default' by 
> default.
>  Also, now the prerequisite is to at least have one export or import API call 
> in order to get this 'default' initialized.
>  The change-marker is obtained prior to invoking export and hence the all 
> policy is bound to fail unless we mandate calling Export or Import API 
> outside hive replication once to get this object initialized, even if hive 
> uses 'default' in the call.
>  
> *Root cause*
> We switched from using
> {code:java}
> atlas.cluster.name{code}
> to
> {code:java}
> atlas.metadata.namespace{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3989) Behavior change in Atlas API to get Atlas Server object during metadata replication

2020-10-09 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3989:
---
Attachment: ATLAS-3989-Updated-Export-Import-Audits-Writer-to-us.patch

> Behavior change in Atlas API to get Atlas Server object during metadata 
> replication
> ---
>
> Key: ATLAS-3989
> URL: https://issues.apache.org/jira/browse/ATLAS-3989
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> ATLAS-3989-Updated-Export-Import-Audits-Writer-to-us.patch
>
>
> There is a change being noticed in the Atlas server API used during atlas 
> metadata replication in hive.
> Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster 
> name, used to work.
> Now, it doesn't work any more. This Api is used during replication to get the 
> changeMarker info.
> Now the API works with some thing called server name which is 'default' by 
> default.
> Also, now the prerequisite is to at least have one export or import API call 
> in order to get this 'default' initialized.
> The change-marker is obtained prior to invoking export and hence the all 
> policy is bound to fail unless we mandate calling Export or Import API 
> outside hive replication once to get this object initialized, even if hive 
> uses 'default' in the call.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-3989) Behavior change in Atlas API to get Atlas Server object during metadata replication

2020-10-09 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-3989:
--

 Summary: Behavior change in Atlas API to get Atlas Server object 
during metadata replication
 Key: ATLAS-3989
 URL: https://issues.apache.org/jira/browse/ATLAS-3989
 Project: Atlas
  Issue Type: Bug
  Components:  atlas-core
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry


There is a change being noticed in the Atlas server API used during atlas 
metadata replication in hive.
Earlier the API: '/api/atlas/admin/server/cl1' where 'cl1' is the cluster name, 
used to work.
Now, it doesn't work any more. This Api is used during replication to get the 
changeMarker info.
Now the API works with some thing called server name which is 'default' by 
default.
Also, now the prerequisite is to at least have one export or import API call in 
order to get this 'default' initialized.
The change-marker is obtained prior to invoking export and hence the all policy 
is bound to fail unless we mandate calling Export or Import API outside hive 
replication once to get this object initialized, even if hive uses 'default' in 
the call.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Comment Edited] (ATLAS-3977) Migration Script: Deleted entities in Atlas1.0 miss few attributes after migrated to Atlas2.0

2020-10-06 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208482#comment-17208482
 ] 

Ashutosh Mestry edited comment on ATLAS-3977 at 10/6/20, 9:41 PM:
--

[~sarath] / [~nixon] / [~nikhilbonte] Can you please review.

Pre-commit build: 
https://ci-builds.apache.org/job/Atlas/job/PreCommit-ATLAS-Build-Test/63/


was (Author: ashutoshm):
[~sarath] / [~nixon] / [~nikhilbonte] Can you please review.

> Migration Script: Deleted entities in Atlas1.0 miss few attributes after 
> migrated to Atlas2.0
> -
>
> Key: ATLAS-3977
> URL: https://issues.apache.org/jira/browse/ATLAS-3977
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Sharmadha S
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-3977-Addressed-patch-processing-for.patch, 
> am2cm_deleted_active_entity.png
>
>
> table6 is DELETED in Atlas1.0 and it is migrated to Atals2.0
> Attributes like name , db , owner are missing in DELETED entities whereas 
> they are populated correctly in ACTIVE entities.
> Attaching the screenshot.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3977) Migration Script: Deleted entities in Atlas1.0 miss few attributes after migrated to Atlas2.0

2020-10-05 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17208482#comment-17208482
 ] 

Ashutosh Mestry commented on ATLAS-3977:


[~sarath] / [~nixon] / [~nikhilbonte] Can you please review.

> Migration Script: Deleted entities in Atlas1.0 miss few attributes after 
> migrated to Atlas2.0
> -
>
> Key: ATLAS-3977
> URL: https://issues.apache.org/jira/browse/ATLAS-3977
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Sharmadha S
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-3977-Addressed-patch-processing-for.patch, 
> am2cm_deleted_active_entity.png
>
>
> table6 is DELETED in Atlas1.0 and it is migrated to Atals2.0
> Attributes like name , db , owner are missing in DELETED entities whereas 
> they are populated correctly in ACTIVE entities.
> Attaching the screenshot.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-3977) Migration Script: Deleted entities in Atlas1.0 miss few attributes after migrated to Atlas2.0

2020-10-05 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-3977:
--

Attachment: ATLAS-3977-Addressed-patch-processing-for.patch
  Assignee: Ashutosh Mestry

> Migration Script: Deleted entities in Atlas1.0 miss few attributes after 
> migrated to Atlas2.0
> -
>
> Key: ATLAS-3977
> URL: https://issues.apache.org/jira/browse/ATLAS-3977
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Reporter: Sharmadha S
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-3977-Addressed-patch-processing-for.patch, 
> am2cm_deleted_active_entity.png
>
>
> table6 is DELETED in Atlas1.0 and it is migrated to Atals2.0
> Attributes like name , db , owner are missing in DELETED entities whereas 
> they are populated correctly in ACTIVE entities.
> Attaching the screenshot.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-10-01 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry resolved ATLAS-3953.

Resolution: Fixed

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> ATLAS-3953-Export-ZipSink-Specify-character-endcodin.patch, 
> Asset_Imported.PNG, AtlasServer.PNG, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, atlas_export.zip, path.zip
>
>
> The Export API returns a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having an issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API but without success.
> After analyzing the Atlas source code, especially the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I thought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with another encoding than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> It's my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible to set the default to encode to the platform or JVM, 
> but how they said in this below discussion, perhaps this doesn't work 
> properly in all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-29 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204390#comment-17204390
 ] 

Ashutosh Mestry commented on ATLAS-3953:


Pre-commit build: 
[https://ci-builds.apache.org/job/Atlas/job/PreCommit-ATLAS-Build-Test/33/]

 

[~nikhilbonte] / [~nixon] / [~sarath]: If you could add +1 to this I can 
proceed with commit. 

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> ATLAS-3953-Export-ZipSink-Specify-character-endcodin.patch, 
> Asset_Imported.PNG, AtlasServer.PNG, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, atlas_export.zip, path.zip
>
>
> The Export API returns a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having an issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API but without success.
> After analyzing the Atlas source code, especially the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I thought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with another encoding than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> It's my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible to set the default to encode to the platform or JVM, 
> but how they said in this below discussion, perhaps this doesn't work 
> properly in all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-29 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17204389#comment-17204389
 ] 

Ashutosh Mestry commented on ATLAS-3953:


[~carlosrochacardoso] That is great news! I will proceed with next steps. 
Thanks for verifying this for me! I appreciate it.

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> ATLAS-3953-Export-ZipSink-Specify-character-endcodin.patch, 
> Asset_Imported.PNG, AtlasServer.PNG, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, atlas_export.zip, path.zip
>
>
> The Export API returns a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having an issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API but without success.
> After analyzing the Atlas source code, especially the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I thought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with another encoding than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> It's my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible to set the default to encode to the platform or JVM, 
> but how they said in this below discussion, perhaps this doesn't work 
> properly in all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-24 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201698#comment-17201698
 ] 

Ashutosh Mestry commented on ATLAS-3953:


Thanks for your interest.

Please take a look at: [http://atlas.apache.org/#/BuildInstallation]

This patch will apply to master: [https://github.com/apache/atlas.git]

I will try at my end to duplicate the issue and then use the solution.

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> ATLAS-3953-Export-ZipSink-Specify-character-endcodin.patch, AtlasServer.PNG, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, path.zip
>
>
> The Export API returns a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having an issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API but without success.
> After analyzing the Atlas source code, especially the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I thought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with another encoding than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> It's my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible to set the default to encode to the platform or JVM, 
> but how they said in this below discussion, perhaps this doesn't work 
> properly in all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3953:
---
Attachment: ATLAS-3953-Export-ZipSink-Specify-character-endcodin.patch

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> ATLAS-3953-Export-ZipSink-Specify-character-endcodin.patch, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, path.zip
>
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17201000#comment-17201000
 ] 

Ashutosh Mestry commented on ATLAS-3953:


I have attached couple of things:
 * _path.zip_: Exported zip file that contains entity with special characters 
in it.
 * _a5c...json_:  Entity represented within Atlas.

I was not able to duplicate the problem.

I also have a patch that specifies _UTF-8_ encoding when writing string to the 
ZIP stream. Would you be able to try out the patch? 

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, path.zip
>
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3953:
---
Attachment: path.zip

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, path.zip
>
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3953:
---
Attachment: a5c148bf-5ab6-4c49-853e-855842102128.json

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 9fdc3ad0-46c2-430a-89c4-4a751d31c064.json, 
> a5c148bf-5ab6-4c49-853e-855842102128.json, path.zip
>
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17200984#comment-17200984
 ] 

Ashutosh Mestry commented on ATLAS-3953:


[~carlosrochacardoso] Thanks for filing this JIRA.

If you attach a sample, I can verify it with my fix.

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3953:
---
Priority: Major  (was: Minor)

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Major
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-3953) JSON Files from Export API with "?" char for string with special chars

2020-09-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-3953:
--

Assignee: Ashutosh Mestry

> JSON Files from Export API with "?" char for string with special chars 
> ---
>
> Key: ATLAS-3953
> URL: https://issues.apache.org/jira/browse/ATLAS-3953
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.1.0
> Environment: Apache Atlas 2.1.0 embedded HBASE and SOLR
>Reporter: Carlos Alberto Rocha Cardoso
>Assignee: Ashutosh Mestry
>Priority: Minor
>
> The Export API return a ZIP file with some JSON files describing Atlas 
> Entities and TypeDefs.
> I am having a issue where some special chars in JSON are being replaced by 
> "?" chars.
> An Entity name like "Distribuição" was exported in JSON file like 
> "Distribui??o". The special chars "çã" was replaced for the "??" chars.
> I tried to change the exported JSON file encoding and the request header for 
> Export API, but without success.
> After analyzing the Atlas source code, specialy the *splitAndWriteBytes* 
> method of the 
> *[ZipSink|https://github.com/apache/atlas/blob/cc601d7371fae1dbc16b55d1ca84f06b745700dc/repository/src/main/java/org/apache/atlas/repository/impexp/ZipSink.java]
>  class*, I tought if maybe the problem is because the *s.getBytes()* is 
> returning the JSON string to be written to ZIP with other encode than 
> *UTF-8*, and maybe set the encode like *s.getBytes(StandardCharsets.UTF_8)* 
> could be a solution.
> Its my first contact with the Atlas source code, and I'm not a JAVA 
> programmer, so it's only a guess.
> I saw that it's possible set the default encode to the plataform, or JVM, but 
> how they said in this below discussion, perhaps this doesn't work properly in 
> all situations.
> [https://stackoverflow.com/questions/361975/setting-the-default-java-character-encoding]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3427) Atlas hooks enhancements for better fault-tolerance i.e. Kafka unavailability

2020-09-21 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3427:
---
Description: 
*Background*

Existing implementation for sending messages from the hooks relies on Kafka. 
Which means that if Kafka is not available for any reasons, the messages do not 
make it to Atlas. They are simply added to the _failed_._log_.

 *Solution*

Introduce a mechanism which preserves messages if destination for the messages 
is not reachable. This new mechanism will also have logic to retry these 
messages.

*Requirements*

The mechanism should be:
 * Transparent: Existing hooks should not have to rework their implementation. 
 * Configurable: This should be introduced optionally. If hook chooses not to 
use this, it should fallback to existing implementation. The behavior should be 
configurable via properties.
 * High-performance: Using this mechanism should not introduce additional 
overhead. Ideally, there should not be additional serialization introduced.
 * Reliable: The new mechanism should relay these messages reliably. Existing 
message formats should be supported viz. plain, compressed, compress & 
multi-part.

 

  was:
*Background*

Existing implementation for sending messages from the hooks relies on Kafka. 
Which means that if Kafka is not available for any reasons, the messages do not 
make it to Atlas. They are simply added to the _failed_._log_.

 

*Solution*

Introduce a mechanism which preserves messages if destination for the messages 
is not reachable. This new mechanism will also have logic to retry these 
messages.


> Atlas hooks enhancements for better fault-tolerance i.e. Kafka unavailability
> -
>
> Key: ATLAS-3427
> URL: https://issues.apache.org/jira/browse/ATLAS-3427
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Nixon Rodrigues
>Assignee: Ashutosh Mestry
>Priority: Major
>
> *Background*
> Existing implementation for sending messages from the hooks relies on Kafka. 
> Which means that if Kafka is not available for any reasons, the messages do 
> not make it to Atlas. They are simply added to the _failed_._log_.
>  *Solution*
> Introduce a mechanism which preserves messages if destination for the 
> messages is not reachable. This new mechanism will also have logic to retry 
> these messages.
> *Requirements*
> The mechanism should be:
>  * Transparent: Existing hooks should not have to rework their 
> implementation. 
>  * Configurable: This should be introduced optionally. If hook chooses not to 
> use this, it should fallback to existing implementation. The behavior should 
> be configurable via properties.
>  * High-performance: Using this mechanism should not introduce additional 
> overhead. Ideally, there should not be additional serialization introduced.
>  * Reliable: The new mechanism should relay these messages reliably. Existing 
> message formats should be supported viz. plain, compressed, compress & 
> multi-part.
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3427) Atlas hooks enhancements for better fault-tolerance i.e. Kafka unavailability

2020-09-21 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3427:
---
Description: 
*Background*

Existing implementation for sending messages from the hooks relies on Kafka. 
Which means that if Kafka is not available for any reasons, the messages do not 
make it to Atlas. They are simply added to the _failed_._log_.

 

*Solution*

Introduce a mechanism which preserves messages if destination for the messages 
is not reachable. This new mechanism will also have logic to retry these 
messages.

  was:
Currently if hooks are not able to reach Kafka, metadata updates are not posted 
and received by Atlas service.

Add a mechanism to make Hooks fault tolerant.


> Atlas hooks enhancements for better fault-tolerance i.e. Kafka unavailability
> -
>
> Key: ATLAS-3427
> URL: https://issues.apache.org/jira/browse/ATLAS-3427
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Nixon Rodrigues
>Assignee: Ashutosh Mestry
>Priority: Major
>
> *Background*
> Existing implementation for sending messages from the hooks relies on Kafka. 
> Which means that if Kafka is not available for any reasons, the messages do 
> not make it to Atlas. They are simply added to the _failed_._log_.
>  
> *Solution*
> Introduce a mechanism which preserves messages if destination for the 
> messages is not reachable. This new mechanism will also have logic to retry 
> these messages.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-3427) Atlas hooks enhancements for better fault-tolerance i.e. Kafka unavailability

2020-09-21 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-3427:
--

Assignee: Ashutosh Mestry  (was: Nixon Rodrigues)

> Atlas hooks enhancements for better fault-tolerance i.e. Kafka unavailability
> -
>
> Key: ATLAS-3427
> URL: https://issues.apache.org/jira/browse/ATLAS-3427
> Project: Atlas
>  Issue Type: Improvement
>Reporter: Nixon Rodrigues
>Assignee: Ashutosh Mestry
>Priority: Major
>
> Currently if hooks are not able to reach Kafka, metadata updates are not 
> posted and received by Atlas service.
> Add a mechanism to make Hooks fault tolerant.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3948) Entity Creation: Index Consistency: Java Patch Handler: Provide Option to Disable

2020-09-17 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3948:
---
Attachment: ATLAS-3948-index-consistency-conditional.patch

> Entity Creation: Index Consistency: Java Patch Handler: Provide Option to 
> Disable
> -
>
> Key: ATLAS-3948
> URL: https://issues.apache.org/jira/browse/ATLAS-3948
> Project: Atlas
>  Issue Type: Bug
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: ATLAS-3948-index-consistency-conditional.patch
>
>
> *Background*
> The ATLAS-3907 provided ability to apply index consistency to existing 
> indexes via Java patch handler.
> However, when _atlas.graph.storage.consistency-lock.enabled=false_ this patch 
> still gets applied.
> *Solution*
> Check for the property in Java patch handler and avoid applying it if the 
> property is set to false.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-3948) Entity Creation: Index Consistency: Java Patch Handler: Provide Option to Disable

2020-09-17 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-3948:
--

 Summary: Entity Creation: Index Consistency: Java Patch Handler: 
Provide Option to Disable
 Key: ATLAS-3948
 URL: https://issues.apache.org/jira/browse/ATLAS-3948
 Project: Atlas
  Issue Type: Bug
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry


*Background*

The ATLAS-3907 provided ability to apply index consistency to existing indexes 
via Java patch handler.

However, when _atlas.graph.storage.consistency-lock.enabled=false_ this patch 
still gets applied.

*Solution*

Check for the property in Java patch handler and avoid applying it if the 
property is set to false.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-09-14 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3941:
---
Attachment: ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch

> NotificationHookConsumer: Reduce Retry Pause Interval
> -
>
> Key: ATLAS-3941
> URL: https://issues.apache.org/jira/browse/ATLAS-3941
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch
>
>
> *Background*
> The retry logic introduced earlier, had a long wait time in case a concurrent 
> entity create was detected. This adversely affect ingest speed in the case 
> where there are a lot of errors in the data being ingested.
> *Solution*
> Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-09-14 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3941:
---
Attachment: (was: 
ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch)

> NotificationHookConsumer: Reduce Retry Pause Interval
> -
>
> Key: ATLAS-3941
> URL: https://issues.apache.org/jira/browse/ATLAS-3941
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch
>
>
> *Background*
> The retry logic introduced earlier, had a long wait time in case a concurrent 
> entity create was detected. This adversely affect ingest speed in the case 
> where there are a lot of errors in the data being ingested.
> *Solution*
> Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-09-14 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3941:
---
Attachment: ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch

> NotificationHookConsumer: Reduce Retry Pause Interval
> -
>
> Key: ATLAS-3941
> URL: https://issues.apache.org/jira/browse/ATLAS-3941
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3941-NotificationHookConsumer-Reduce-wait-time.patch
>
>
> *Background*
> The retry logic introduced earlier, had a long wait time in case a concurrent 
> entity create was detected. This adversely affect ingest speed in the case 
> where there are a lot of errors in the data being ingested.
> *Solution*
> Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-3941) NotificationHookConsumer: Reduce Retry Pause Interval

2020-09-14 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-3941:
--

 Summary: NotificationHookConsumer: Reduce Retry Pause Interval
 Key: ATLAS-3941
 URL: https://issues.apache.org/jira/browse/ATLAS-3941
 Project: Atlas
  Issue Type: Bug
  Components:  atlas-core
Affects Versions: 2.1.0, trunk
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry
 Fix For: trunk


*Background*

The retry logic introduced earlier, had a long wait time in case a concurrent 
entity create was detected. This adversely affect ingest speed in the case 
where there are a lot of errors in the data being ingested.

*Solution*

Reduce the wait time.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-2932) Update DSL to use Java Traversal API

2020-08-27 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-2932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-2932:
--

Assignee: Ashutosh Mestry  (was: Apoorv Naik)

> Update DSL to use Java Traversal API
> 
>
> Key: ATLAS-2932
> URL: https://issues.apache.org/jira/browse/ATLAS-2932
> Project: Atlas
>  Issue Type: Bug
>Affects Versions: 1.0.0, trunk
>Reporter: Apoorv Naik
>Assignee: Ashutosh Mestry
>Priority: Major
> Attachments: 
> 0002-ATLAS-2932-Update-DSL-to-use-Tinkerpop-Java-APIs-ins.patch
>
>
> Change DSL code to use Java Tinkerpop Traversals instead of 
> GremlinScriptEngine



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3082) /var/log/atlas/application.log has unclear message

2020-08-17 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3082:
---
Priority: Major  (was: Minor)

>  /var/log/atlas/application.log has unclear message
> ---
>
> Key: ATLAS-3082
> URL: https://issues.apache.org/jira/browse/ATLAS-3082
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0
>Reporter: Xinran Tinney
>Assignee: Ashutosh Mestry
>Priority: Major
>
> In /var/log/atlas/application.log every time the home page loads, there is 
> this error in the logs:
> "graph rollback due to exception AtlasBaseException:Instance 
> __AtlasUserProfile with unique attribute \{name=admin} does not exist"  This 
> should be removed.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-3082) /var/log/atlas/application.log has unclear message

2020-08-17 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-3082:
--

Assignee: Ashutosh Mestry  (was: Xinran Tinney)

>  /var/log/atlas/application.log has unclear message
> ---
>
> Key: ATLAS-3082
> URL: https://issues.apache.org/jira/browse/ATLAS-3082
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0
>Reporter: Xinran Tinney
>Assignee: Ashutosh Mestry
>Priority: Minor
>
> In /var/log/atlas/application.log every time the home page loads, there is 
> this error in the logs:
> "graph rollback due to exception AtlasBaseException:Instance 
> __AtlasUserProfile with unique attribute \{name=admin} does not exist"  This 
> should be removed.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3874) NotificationHookConsumer: Shell Entity Resolution When Multiple Consumers Process Same Entity

2020-08-03 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3874:
---
Attachment: (was: 
ATLAS-3874-Notification-hook-processing-concurrent-e.patch)

> NotificationHookConsumer: Shell Entity Resolution When Multiple Consumers 
> Process Same Entity
> -
>
> Key: ATLAS-3874
> URL: https://issues.apache.org/jira/browse/ATLAS-3874
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
>
> *Background*
> Atlas has ability to consume messages from multiple hooks. When doing so, if 
> there are messages in multiple queue requesting creation of  the same entity, 
> then this case leads to a race condition. 
> *Steps to Duplicate*
> _Pre-requisites_
> Atlas should be configured to consume from 2 Kafka queues viz. _queue1_ and 
> _queue2_.
> _Steps:_
>  # Add a message in _queue1_ that references a non-existent entity.
>  # Add a message in _queue2_ that creates the entity in step 1.
> _Expected behavior_:
> Shell entity should get created in step 1 that is resolved into first class 
> entity in step 2.
> _Actual behavior:_
> Shell entity is not resolved. A duplicate entity with same _qualifiedName_ 
> gets created.
> *Root Cause*
> The _NotificationHookConsumer_ is not aware of messages processed by other 
> consumers there by leading to concurrent entity creation. 
>  



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (ATLAS-3878) Notifications: Improve Memory Usage in Scale Enviroment

2020-08-03 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry resolved ATLAS-3878.

Resolution: Fixed

> Notifications: Improve Memory Usage in Scale Enviroment
> ---
>
> Key: ATLAS-3878
> URL: https://issues.apache.org/jira/browse/ATLAS-3878
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3878-Notifications-Improve-Memory-Usage-in-Sca-v2.patch
>
>
> *Background*
> As part of entity creation, Atlas sends notifications of different types. 
> Current implementation, to listeners. Listeners in turn perform specific 
> tasks.
> At a more concrete level, the _EntityAuditListenerV2_ will write audits and 
> the _NotificationEntityChangeListener_ will send Kafka notifications.
> Each of the listeners create notification objects. The notification objects 
> are large in number and are short lived.
> The transient nature of the notification objects causes memory pressure in 
> scale environment.
> *Solution*
> Create object pool for notification objects. This way objects can be 
> reused.and existing design can be kept in tact. This will also offer benefit 
> of using existing test setup for verification.
> *Tests Used*
> _Setup_ 
> Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
> APIs for entity creation.
> Node: 40 workers, 8 GB allocated memory and 40 cores.
> _Observation_
> About 40 mins into the exercise, memory pressure builds up causing GC 
> collects to take longer. This causes ZK timeout and finally Atlas process 
> crashes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Assigned] (ATLAS-3398) Duplicates for unique attributes

2020-07-31 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry reassigned ATLAS-3398:
--

Assignee: Ashutosh Mestry

> Duplicates for unique attributes 
> -
>
> Key: ATLAS-3398
> URL: https://issues.apache.org/jira/browse/ATLAS-3398
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Bolke de Bruin
>Assignee: Ashutosh Mestry
>Priority: Blocker
>  Labels: integrity
> Attachments: zrzut_ekranu_2019-09-03_o_10.28.50.png
>
>
> We are seeing issues with entities being added to Atlas with duplicate 
> "qualifiedName". The guids differ and other attributes do also differ. Below 
> a graph that shows the distribution over time for duplicates. We have 
> difficulty determining which one is the right one (as they are different) in 
> order to clean them up.
> We are also not the only ones encountering this as you can in the linked 
> issue.
> We have noticed that Atlas does not use the 
> [locking|https://docs.janusgraph.org/master/advanced-topics/eventual-consistency/]
>  mechanism of Janus to prevent this:
>  
> !zrzut_ekranu_2019-09-03_o_10.28.50.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3398) Duplicates for unique attributes

2020-07-31 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17168967#comment-17168967
 ] 

Ashutosh Mestry commented on ATLAS-3398:


[~dwarszawski] I am not able to assign this issue to you. Your name does not 
show up in the list for some reason. I have assigned it to me for tracking. 
Hope that is OK.

> Duplicates for unique attributes 
> -
>
> Key: ATLAS-3398
> URL: https://issues.apache.org/jira/browse/ATLAS-3398
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Bolke de Bruin
>Assignee: Ashutosh Mestry
>Priority: Blocker
>  Labels: integrity
> Attachments: zrzut_ekranu_2019-09-03_o_10.28.50.png
>
>
> We are seeing issues with entities being added to Atlas with duplicate 
> "qualifiedName". The guids differ and other attributes do also differ. Below 
> a graph that shows the distribution over time for duplicates. We have 
> difficulty determining which one is the right one (as they are different) in 
> order to clean them up.
> We are also not the only ones encountering this as you can in the linked 
> issue.
> We have noticed that Atlas does not use the 
> [locking|https://docs.janusgraph.org/master/advanced-topics/eventual-consistency/]
>  mechanism of Janus to prevent this:
>  
> !zrzut_ekranu_2019-09-03_o_10.28.50.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Resolved] (ATLAS-3398) Duplicates for unique attributes

2020-07-31 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry resolved ATLAS-3398.

Resolution: Fixed

> Duplicates for unique attributes 
> -
>
> Key: ATLAS-3398
> URL: https://issues.apache.org/jira/browse/ATLAS-3398
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Bolke de Bruin
>Assignee: Ashutosh Mestry
>Priority: Blocker
>  Labels: integrity
> Attachments: zrzut_ekranu_2019-09-03_o_10.28.50.png
>
>
> We are seeing issues with entities being added to Atlas with duplicate 
> "qualifiedName". The guids differ and other attributes do also differ. Below 
> a graph that shows the distribution over time for duplicates. We have 
> difficulty determining which one is the right one (as they are different) in 
> order to clean them up.
> We are also not the only ones encountering this as you can in the linked 
> issue.
> We have noticed that Atlas does not use the 
> [locking|https://docs.janusgraph.org/master/advanced-topics/eventual-consistency/]
>  mechanism of Janus to prevent this:
>  
> !zrzut_ekranu_2019-09-03_o_10.28.50.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-3907) Entity Creation: Index Consistency: Java Patch Handler

2020-07-30 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-3907:
--

 Summary: Entity Creation: Index Consistency: Java Patch Handler
 Key: ATLAS-3907
 URL: https://issues.apache.org/jira/browse/ATLAS-3907
 Project: Atlas
  Issue Type: Bug
  Components:  atlas-core
Affects Versions: trunk
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry
 Fix For: trunk


*Background*

[ATLAS-3398|https://issues.apache.org/jira/browse/ATLAS-3398] adds 
_setConsistency_ during index creation. This works well for net new Atlas 
deployments.

This Jira attempts to address the case where Atlas has been deployed and in-use 
without this change to the indexes.

*Proposed Approach*
 * Use Atlas' java patch framework.
 * Create a java patch that enumerates existing indexes. This should be 
possible using JanusGraph's native APIs.
 * Add the _setConsistency_ to existing indexes.

[~dwarszawski] : Thanks for your earlier patch.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3902) Import Service: Importing Data With Differing GUIDs for Same Unique Attributes Causes Errors in Certain Cases

2020-07-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3902:
---
Summary: Import Service: Importing Data With Differing GUIDs for Same 
Unique Attributes Causes Errors in Certain Cases  (was: Import Service: 
Importing Data With Differing GUIDs for Same Unique Attributes Causes Errors)

> Import Service: Importing Data With Differing GUIDs for Same Unique 
> Attributes Causes Errors in Certain Cases
> -
>
> Key: ATLAS-3902
> URL: https://issues.apache.org/jira/browse/ATLAS-3902
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk, 2.1.0
>
>
> *Background*
> Consider the scenario where 2 clusters containing Atlas are setup to be 
> synchronized Atlas' export and import APIs. If the source Atlas has changes 
> where table is dropped and re-created with same name. The table's entity 
> within Atlas  will get a new GUID but will continue to have the same 
> _qualifiedName_.
> This case is handled within the Import API.
> However, the case that is not handled is to perform similar update on to the 
> table's storage descriptor.
> *Steps to Duplicate*
>  # Create a schema within Hive containing database, tables, columns and 
> views. Atlas will reflect the changes. Perform export. Generate _s1.zip_.
>  # Drop schema.
>  # Re-create the same schema within Hive. Perform export. Generate _s2.zip_.
>  # Clear Atlas database.
>  # Import _s1.zip_. Observe _application.log_.
>  # Import s2.zip. Observe _application.log_. During import log will generate 
> messages like '_GUID Updated: Entity..._'
> _Expected result:_ Import should succeed with messages indicating changes 
> entity's GUID.
> _Actual result_: Import fails with errors indicating schema violation 
> (_AtlasSchemaViolation_)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3902) Import Service: Importing Data With Differing GUIDs for Same Unique Attributes Causes Errors

2020-07-23 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3902:
---
Description: 
*Background*

Consider the scenario where 2 clusters containing Atlas are setup to be 
synchronized Atlas' export and import APIs. If the source Atlas has changes 
where table is dropped and re-created with same name. The table's entity within 
Atlas  will get a new GUID but will continue to have the same _qualifiedName_.

This case is handled within the Import API.

However, the case that is not handled is to perform similar update on to the 
table's storage descriptor.

*Steps to Duplicate*
 # Create a schema within Hive containing database, tables, columns and views. 
Atlas will reflect the changes. Perform export. Generate _s1.zip_.
 # Drop schema.
 # Re-create the same schema within Hive. Perform export. Generate _s2.zip_.
 # Clear Atlas database.
 # Import _s1.zip_. Observe _application.log_.
 # Import s2.zip. Observe _application.log_. During import log will generate 
messages like '_GUID Updated: Entity..._'

_Expected result:_ Import should succeed with messages indicating changes 
entity's GUID.

_Actual result_: Import fails with errors indicating schema violation 
(_AtlasSchemaViolation_)

  was:
*Background*

*Steps to Duplicate*
 # Create a schema within Hive containing database, tables, columns and views. 
Atlas will reflect the changes. Perform export. Generate _s1.zip_.
 # Drop schema.
 # Re-create the same schema within Hive. Perform export. Generate _s2.zip_.
 # Clear Atlas database.
 # Import _s1.zip_. Observe _application.log_.
 # Import s2.zip. Observe _application.log_. During import log will generate 
messages like '_GUID Updated: Entity..._'

_Expected result:_ Import should succeed with messages indicating changes 
entity's GUID.

_Actual result_: Import fails with errors indicating schema violation 
(_AtlasSchemaViolation_)


> Import Service: Importing Data With Differing GUIDs for Same Unique 
> Attributes Causes Errors
> 
>
> Key: ATLAS-3902
> URL: https://issues.apache.org/jira/browse/ATLAS-3902
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk, 2.1.0
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk, 2.1.0
>
>
> *Background*
> Consider the scenario where 2 clusters containing Atlas are setup to be 
> synchronized Atlas' export and import APIs. If the source Atlas has changes 
> where table is dropped and re-created with same name. The table's entity 
> within Atlas  will get a new GUID but will continue to have the same 
> _qualifiedName_.
> This case is handled within the Import API.
> However, the case that is not handled is to perform similar update on to the 
> table's storage descriptor.
> *Steps to Duplicate*
>  # Create a schema within Hive containing database, tables, columns and 
> views. Atlas will reflect the changes. Perform export. Generate _s1.zip_.
>  # Drop schema.
>  # Re-create the same schema within Hive. Perform export. Generate _s2.zip_.
>  # Clear Atlas database.
>  # Import _s1.zip_. Observe _application.log_.
>  # Import s2.zip. Observe _application.log_. During import log will generate 
> messages like '_GUID Updated: Entity..._'
> _Expected result:_ Import should succeed with messages indicating changes 
> entity's GUID.
> _Actual result_: Import fails with errors indicating schema violation 
> (_AtlasSchemaViolation_)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-3902) Import Service: Importing Data With Differing GUIDs for Same Unique Attributes Causes Errors

2020-07-23 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-3902:
--

 Summary: Import Service: Importing Data With Differing GUIDs for 
Same Unique Attributes Causes Errors
 Key: ATLAS-3902
 URL: https://issues.apache.org/jira/browse/ATLAS-3902
 Project: Atlas
  Issue Type: Bug
  Components:  atlas-core
Affects Versions: 2.1.0, 2.0.0, trunk
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry
 Fix For: trunk, 2.1.0


*Background*

*Steps to Duplicate*
 # Create a schema within Hive containing database, tables, columns and views. 
Atlas will reflect the changes. Perform export. Generate _s1.zip_.
 # Drop schema.
 # Re-create the same schema within Hive. Perform export. Generate _s2.zip_.
 # Clear Atlas database.
 # Import _s1.zip_. Observe _application.log_.
 # Import s2.zip. Observe _application.log_. During import log will generate 
messages like '_GUID Updated: Entity..._'

_Expected result:_ Import should succeed with messages indicating changes 
entity's GUID.

_Actual result_: Import fails with errors indicating schema violation 
(_AtlasSchemaViolation_)



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Commented] (ATLAS-3398) Duplicates for unique attributes

2020-07-20 Thread Ashutosh Mestry (Jira)


[ 
https://issues.apache.org/jira/browse/ATLAS-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161588#comment-17161588
 ] 

Ashutosh Mestry commented on ATLAS-3398:


I suppose the way to duplicate would be to attempt to create entities via REST 
APIs?

Test case would be to have entity payload with same _qualifiedName_ but 
different GUIDs and execute them at the same moment.

> Duplicates for unique attributes 
> -
>
> Key: ATLAS-3398
> URL: https://issues.apache.org/jira/browse/ATLAS-3398
> Project: Atlas
>  Issue Type: Bug
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Bolke de Bruin
>Priority: Blocker
>  Labels: integrity
> Attachments: zrzut_ekranu_2019-09-03_o_10.28.50.png
>
>
> We are seeing issues with entities being added to Atlas with duplicate 
> "qualifiedName". The guids differ and other attributes do also differ. Below 
> a graph that shows the distribution over time for duplicates. We have 
> difficulty determining which one is the right one (as they are different) in 
> order to clean them up.
> We are also not the only ones encountering this as you can in the linked 
> issue.
> We have noticed that Atlas does not use the 
> [locking|https://docs.janusgraph.org/master/advanced-topics/eventual-consistency/]
>  mechanism of Janus to prevent this:
>  
> !zrzut_ekranu_2019-09-03_o_10.28.50.png!



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3878) Notifications: Improve Memory Usage in Scale Enviroment

2020-07-08 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3878:
---
Attachment: (was: notifications-memory-fix-v3.patch)

> Notifications: Improve Memory Usage in Scale Enviroment
> ---
>
> Key: ATLAS-3878
> URL: https://issues.apache.org/jira/browse/ATLAS-3878
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3878-Notifications-Improve-Memory-Usage-in-Sca-v2.patch
>
>
> *Background*
> As part of entity creation, Atlas sends notifications of different types. 
> Current implementation, to listeners. Listeners in turn perform specific 
> tasks.
> At a more concrete level, the _EntityAuditListenerV2_ will write audits and 
> the _NotificationEntityChangeListener_ will send Kafka notifications.
> Each of the listeners create notification objects. The notification objects 
> are large in number and are short lived.
> The transient nature of the notification objects causes memory pressure in 
> scale environment.
> *Solution*
> Create object pool for notification objects. This way objects can be 
> reused.and existing design can be kept in tact. This will also offer benefit 
> of using existing test setup for verification.
> *Tests Used*
> _Setup_ 
> Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
> APIs for entity creation.
> Node: 40 workers, 8 GB allocated memory and 40 cores.
> _Observation_
> About 40 mins into the exercise, memory pressure builds up causing GC 
> collects to take longer. This causes ZK timeout and finally Atlas process 
> crashes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3878) Notifications: Improve Memory Usage in Scale Enviroment

2020-07-08 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3878:
---
Attachment: ATLAS-3878-Notifications-Improve-Memory-Usage-in-Sca-v2.patch

> Notifications: Improve Memory Usage in Scale Enviroment
> ---
>
> Key: ATLAS-3878
> URL: https://issues.apache.org/jira/browse/ATLAS-3878
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: 
> ATLAS-3878-Notifications-Improve-Memory-Usage-in-Sca-v2.patch
>
>
> *Background*
> As part of entity creation, Atlas sends notifications of different types. 
> Current implementation, to listeners. Listeners in turn perform specific 
> tasks.
> At a more concrete level, the _EntityAuditListenerV2_ will write audits and 
> the _NotificationEntityChangeListener_ will send Kafka notifications.
> Each of the listeners create notification objects. The notification objects 
> are large in number and are short lived.
> The transient nature of the notification objects causes memory pressure in 
> scale environment.
> *Solution*
> Create object pool for notification objects. This way objects can be 
> reused.and existing design can be kept in tact. This will also offer benefit 
> of using existing test setup for verification.
> *Tests Used*
> _Setup_ 
> Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
> APIs for entity creation.
> Node: 40 workers, 8 GB allocated memory and 40 cores.
> _Observation_
> About 40 mins into the exercise, memory pressure builds up causing GC 
> collects to take longer. This causes ZK timeout and finally Atlas process 
> crashes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3878) Notifications: Improve Memory Usage in Scale Enviroment

2020-07-08 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3878:
---
Attachment: notifications-memory-fix-v3.patch

> Notifications: Improve Memory Usage in Scale Enviroment
> ---
>
> Key: ATLAS-3878
> URL: https://issues.apache.org/jira/browse/ATLAS-3878
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
> Attachments: notifications-memory-fix-v3.patch
>
>
> *Background*
> As part of entity creation, Atlas sends notifications of different types. 
> Current implementation, to listeners. Listeners in turn perform specific 
> tasks.
> At a more concrete level, the _EntityAuditListenerV2_ will write audits and 
> the _NotificationEntityChangeListener_ will send Kafka notifications.
> Each of the listeners create notification objects. The notification objects 
> are large in number and are short lived.
> The transient nature of the notification objects causes memory pressure in 
> scale environment.
> *Solution*
> Create object pool for notification objects. This way objects can be 
> reused.and existing design can be kept in tact. This will also offer benefit 
> of using existing test setup for verification.
> *Tests Used*
> _Setup_ 
> Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
> APIs for entity creation.
> Node: 40 workers, 8 GB allocated memory and 40 cores.
> _Observation_
> About 40 mins into the exercise, memory pressure builds up causing GC 
> collects to take longer. This causes ZK timeout and finally Atlas process 
> crashes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Updated] (ATLAS-3878) Notifications: Improve Memory Usage in Scale Enviroment

2020-07-08 Thread Ashutosh Mestry (Jira)


 [ 
https://issues.apache.org/jira/browse/ATLAS-3878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Ashutosh Mestry updated ATLAS-3878:
---
Description: 
*Background*

As part of entity creation, Atlas sends notifications of different types. 
Current implementation, to listeners. Listeners in turn perform specific tasks.

At a more concrete level, the _EntityAuditListenerV2_ will write audits and the 
_NotificationEntityChangeListener_ will send Kafka notifications.

Each of the listeners create notification objects. The notification objects are 
large in number and are short lived.

The transient nature of the notification objects causes memory pressure in 
scale environment.

*Solution*

Create object pool for notification objects. This way objects can be reused.and 
existing design can be kept in tact. This will also offer benefit of using 
existing test setup for verification.

*Tests Used*

_Setup_ 

Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
APIs for entity creation.

Node: 40 workers, 8 GB allocated memory and 40 cores.

_Observation_

About 40 mins into the exercise, memory pressure builds up causing GC collects 
to take longer. This causes ZK timeout and finally Atlas process crashes.

  was:
*Background*

As part of entity creation, Atlas sends notifications of different types. 
Current implementation, to listeners. Listeners in turn perform specific tasks.

At a more concrete level, the _EntityAuditListenerV2_ will write audits and the 
_NotificationEntityChangeListener_ will send Kafka notifications.

Each of the listeners create notification objects. The notification objects are 
large in number and are short lived.

The transient nature of the notification objects causes memory pressure in 
scale environment.

*Solution*

Create object pool for notification objects. This way objects can be reused.and 
existing design can be kept in tact. This will also offer benefit of using 
existing test setup for verification.

*Tests Used*

_Setup_ 

Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
APIs for entity creation.

Node: 40 workers, 8 GB allocated memory and 40 cores.

**_Observation_

About 40 mins into the exercise, memory pressure builds up causing GC collects 
to take longer. This causes ZK timeout and finally Atlas process crashes.


> Notifications: Improve Memory Usage in Scale Enviroment
> ---
>
> Key: ATLAS-3878
> URL: https://issues.apache.org/jira/browse/ATLAS-3878
> Project: Atlas
>  Issue Type: Improvement
>  Components:  atlas-core
>Affects Versions: 2.0.0, trunk
>Reporter: Ashutosh Mestry
>Assignee: Ashutosh Mestry
>Priority: Major
> Fix For: trunk
>
>
> *Background*
> As part of entity creation, Atlas sends notifications of different types. 
> Current implementation, to listeners. Listeners in turn perform specific 
> tasks.
> At a more concrete level, the _EntityAuditListenerV2_ will write audits and 
> the _NotificationEntityChangeListener_ will send Kafka notifications.
> Each of the listeners create notification objects. The notification objects 
> are large in number and are short lived.
> The transient nature of the notification objects causes memory pressure in 
> scale environment.
> *Solution*
> Create object pool for notification objects. This way objects can be 
> reused.and existing design can be kept in tact. This will also offer benefit 
> of using existing test setup for verification.
> *Tests Used*
> _Setup_ 
> Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
> APIs for entity creation.
> Node: 40 workers, 8 GB allocated memory and 40 cores.
> _Observation_
> About 40 mins into the exercise, memory pressure builds up causing GC 
> collects to take longer. This causes ZK timeout and finally Atlas process 
> crashes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


[jira] [Created] (ATLAS-3878) Notifications: Improve Memory Usage in Scale Enviroment

2020-07-06 Thread Ashutosh Mestry (Jira)
Ashutosh Mestry created ATLAS-3878:
--

 Summary: Notifications: Improve Memory Usage in Scale Enviroment
 Key: ATLAS-3878
 URL: https://issues.apache.org/jira/browse/ATLAS-3878
 Project: Atlas
  Issue Type: Improvement
  Components:  atlas-core
Affects Versions: 2.0.0, trunk
Reporter: Ashutosh Mestry
Assignee: Ashutosh Mestry
 Fix For: trunk


*Background*

As part of entity creation, Atlas sends notifications of different types. 
Current implementation, to listeners. Listeners in turn perform specific tasks.

At a more concrete level, the _EntityAuditListenerV2_ will write audits and the 
_NotificationEntityChangeListener_ will send Kafka notifications.

Each of the listeners create notification objects. The notification objects are 
large in number and are short lived.

The transient nature of the notification objects causes memory pressure in 
scale environment.

*Solution*

Create object pool for notification objects. This way objects can be reused.and 
existing design can be kept in tact. This will also offer benefit of using 
existing test setup for verification.

*Tests Used*

_Setup_ 

Create a test rig that will spawn multiple works that will invoke Atlas' bulk 
APIs for entity creation.

Node: 40 workers, 8 GB allocated memory and 40 cores.

**_Observation_

About 40 mins into the exercise, memory pressure builds up causing GC collects 
to take longer. This causes ZK timeout and finally Atlas process crashes.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)


<    1   2   3   4   5   6   7   8   9   >