[
https://issues.apache.org/jira/browse/ATLAS-5419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pinal Shah updated ATLAS-5419:
------------------------------
Description:
*Steps to Reproduce:*
* Start Atlas with below property
{code:java}
atlas.notification.consumer.preprocess.entity.type.ignore.pattern=trino.*{code}
* Send kafka messages with ENTITY_CREATE_V2 and ENTITY_PARTIAL_UPDATE_V2
* Monitor application.log grepping "ignored entity:"{*}{{*}}
*Expected:*
* Both notifications ENTITY_CREATE_V2 and ENTITY_PARTIAL_UPDATE_V2 should be
ignored
*Actual:*
* ENTITY_PARTIAL_UPDATE_V2 doesn't ignored, it gets into processing
{*}Logs{*}:
{code:java}
2026-09-24 06:27:30,427 [NotificationHookConsumer thread-0] INFO
[PreprocessorContext.java:276] ignored entity: typeName=trino_catalog,
qualifiedName=iceberg_catalog@cm. topic-offset=0, partition=0{code}
{code:java}
2026-09-24 06:27:31,201 [NotificationHookConsumer thread-0] INFO
[NotificationHookConsumer.java:585] Message type: ENTITY_PARTIAL_UPDATE_V2
2026-09-24 06:27:31,203 [NotificationHookConsumer thread-0] INFO
[GraphTransactionAdvisor.java:43] GraphTransaction intercept for
org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2.updateEntity
2026-09-24 06:27:31,203 [NotificationHookConsumer thread-0] ERROR
[GraphTransactionInterceptor.java:280] graph rollback due to exception
org.apache.atlas.exception.AtlasBaseException: trino_table: Unknown/invalid
typename {code}
was:
*Steps to Reproduce:*
* Start Atlas with below property
{{}}
{code:java}
atlas.notification.consumer.preprocess.entity.type.ignore.pattern=trino.*{code}
* Send kafka messages with ENTITY_CREATE_V2 and ENTITY_PARTIAL_UPDATE_V2
* Monitor application.log grepping "ignored entity:"{*}{*}
*Expected:*
* Both notifications ENTITY_CREATE_V2 and ENTITY_PARTIAL_UPDATE_V2 should be
ignored
*Actual:*
* ENTITY_PARTIAL_UPDATE_V2 doesn't ignored, it gets into processing
{*}Logs{*}:
{code:java}
2026-09-24 06:27:30,427 [NotificationHookConsumer thread-0] INFO
[PreprocessorContext.java:276] ignored entity: typeName=trino_catalog,
qualifiedName=iceberg_catalog@cm. topic-offset=0, partition=0{code}
{code:java}
2026-09-24 06:27:31,201 [NotificationHookConsumer thread-0] INFO
[NotificationHookConsumer.java:585] Message type: ENTITY_PARTIAL_UPDATE_V2
2026-09-24 06:27:31,203 [NotificationHookConsumer thread-0] INFO
[GraphTransactionAdvisor.java:43] GraphTransaction intercept for
org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2.updateEntity
2026-09-24 06:27:31,203 [NotificationHookConsumer thread-0] ERROR
[GraphTransactionInterceptor.java:280] graph rollback due to exception
org.apache.atlas.exception.AtlasBaseException: trino_table: Unknown/invalid
typename {code}
> Ignore/Prune Patterns: entity-partial-updates, entity-delete notifications
> aren't ignored
> -----------------------------------------------------------------------------------------
>
> Key: ATLAS-5419
> URL: https://issues.apache.org/jira/browse/ATLAS-5419
> Project: Atlas
> Issue Type: Bug
> Components: atlas-core
> Reporter: Pinal Shah
> Priority: Major
>
> *Steps to Reproduce:*
> * Start Atlas with below property
> {code:java}
> atlas.notification.consumer.preprocess.entity.type.ignore.pattern=trino.*{code}
> * Send kafka messages with ENTITY_CREATE_V2 and ENTITY_PARTIAL_UPDATE_V2
> * Monitor application.log grepping "ignored entity:"{*}{{*}}
> *Expected:*
> * Both notifications ENTITY_CREATE_V2 and ENTITY_PARTIAL_UPDATE_V2 should be
> ignored
> *Actual:*
> * ENTITY_PARTIAL_UPDATE_V2 doesn't ignored, it gets into processing
> {*}Logs{*}:
> {code:java}
> 2026-09-24 06:27:30,427 [NotificationHookConsumer thread-0] INFO
> [PreprocessorContext.java:276] ignored entity: typeName=trino_catalog,
> qualifiedName=iceberg_catalog@cm. topic-offset=0, partition=0{code}
> {code:java}
> 2026-09-24 06:27:31,201 [NotificationHookConsumer thread-0] INFO
> [NotificationHookConsumer.java:585] Message type: ENTITY_PARTIAL_UPDATE_V2
> 2026-09-24 06:27:31,203 [NotificationHookConsumer thread-0] INFO
> [GraphTransactionAdvisor.java:43] GraphTransaction intercept for
> org.apache.atlas.repository.store.graph.v2.AtlasEntityStoreV2.updateEntity
> 2026-09-24 06:27:31,203 [NotificationHookConsumer thread-0] ERROR
> [GraphTransactionInterceptor.java:280] graph rollback due to exception
> org.apache.atlas.exception.AtlasBaseException: trino_table: Unknown/invalid
> typename {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
